summaryrefslogtreecommitdiffstats
path: root/src/go/collectors/go.d.plugin/agent/discovery/dummy/discovery.go
diff options
context:
space:
mode:
Diffstat (limited to 'src/go/collectors/go.d.plugin/agent/discovery/dummy/discovery.go')
-rw-r--r--src/go/collectors/go.d.plugin/agent/discovery/dummy/discovery.go39
1 files changed, 18 insertions, 21 deletions
diff --git a/src/go/collectors/go.d.plugin/agent/discovery/dummy/discovery.go b/src/go/collectors/go.d.plugin/agent/discovery/dummy/discovery.go
index 40e8d6693b..fed257b2f6 100644
--- a/src/go/collectors/go.d.plugin/agent/discovery/dummy/discovery.go
+++ b/src/go/collectors/go.d.plugin/agent/discovery/dummy/discovery.go
@@ -17,7 +17,8 @@ func NewDiscovery(cfg Config) (*Discovery, error) {
}
d := &Discovery{
Logger: logger.New().With(
- slog.String("component", "discovery dummy"),
+ slog.String("component", "discovery"),
+ slog.String("discoverer", "dummy"),
),
reg: cfg.Registry,
names: cfg.Names,
@@ -52,28 +53,24 @@ func (d *Discovery) Run(ctx context.Context, in chan<- []*confgroup.Group) {
close(in)
}
-func (d *Discovery) groups() (groups []*confgroup.Group) {
+func (d *Discovery) groups() []*confgroup.Group {
+ group := &confgroup.Group{Source: "internal"}
+
for _, name := range d.names {
- groups = append(groups, d.newCfgGroup(name))
- }
- return groups
-}
+ def, ok := d.reg.Lookup(name)
+ if !ok {
+ continue
+ }
+ src := "internal"
+ cfg := confgroup.Config{}
+ cfg.SetModule(name)
+ cfg.SetProvider("dummy")
+ cfg.SetSourceType(confgroup.TypeStock)
+ cfg.SetSource(src)
+ cfg.ApplyDefaults(def)
-func (d *Discovery) newCfgGroup(name string) *confgroup.Group {
- def, ok := d.reg.Lookup(name)
- if !ok {
- return nil
+ group.Configs = append(group.Configs, cfg)
}
- cfg := confgroup.Config{}
- cfg.SetModule(name)
- cfg.SetSource(name)
- cfg.SetProvider("dummy")
- cfg.Apply(def)
-
- group := &confgroup.Group{
- Configs: []confgroup.Config{cfg},
- Source: name,
- }
- return group
+ return []*confgroup.Group{group}
}