From 87d772a7d708fec12f48cd8adc0dedff6e1025da Mon Sep 17 00:00:00 2001 From: Daniel Baumann Date: Mon, 26 Aug 2024 10:15:20 +0200 Subject: Adding upstream version 1.47.0. Signed-off-by: Daniel Baumann --- .../go.d.plugin/agent/discovery/dummy/discovery.go | 76 ---------------------- 1 file changed, 76 deletions(-) delete mode 100644 src/go/collectors/go.d.plugin/agent/discovery/dummy/discovery.go (limited to 'src/go/collectors/go.d.plugin/agent/discovery/dummy/discovery.go') 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 deleted file mode 100644 index fed257b2f..000000000 --- a/src/go/collectors/go.d.plugin/agent/discovery/dummy/discovery.go +++ /dev/null @@ -1,76 +0,0 @@ -// SPDX-License-Identifier: GPL-3.0-or-later - -package dummy - -import ( - "context" - "fmt" - "log/slog" - - "github.com/netdata/netdata/go/go.d.plugin/agent/confgroup" - "github.com/netdata/netdata/go/go.d.plugin/logger" -) - -func NewDiscovery(cfg Config) (*Discovery, error) { - if err := validateConfig(cfg); err != nil { - return nil, fmt.Errorf("config validation: %v", err) - } - d := &Discovery{ - Logger: logger.New().With( - slog.String("component", "discovery"), - slog.String("discoverer", "dummy"), - ), - reg: cfg.Registry, - names: cfg.Names, - } - return d, nil -} - -type Discovery struct { - *logger.Logger - - reg confgroup.Registry - names []string -} - -func (d *Discovery) String() string { - return d.Name() -} - -func (d *Discovery) Name() string { - return "dummy discovery" -} - -func (d *Discovery) Run(ctx context.Context, in chan<- []*confgroup.Group) { - d.Info("instance is started") - defer func() { d.Info("instance is stopped") }() - - select { - case <-ctx.Done(): - case in <- d.groups(): - } - - close(in) -} - -func (d *Discovery) groups() []*confgroup.Group { - group := &confgroup.Group{Source: "internal"} - - for _, name := range d.names { - 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) - - group.Configs = append(group.Configs, cfg) - } - - return []*confgroup.Group{group} -} -- cgit v1.2.3