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/sd/conffile.go | 69 ---------------------- 1 file changed, 69 deletions(-) delete mode 100644 src/go/collectors/go.d.plugin/agent/discovery/sd/conffile.go (limited to 'src/go/collectors/go.d.plugin/agent/discovery/sd/conffile.go') diff --git a/src/go/collectors/go.d.plugin/agent/discovery/sd/conffile.go b/src/go/collectors/go.d.plugin/agent/discovery/sd/conffile.go deleted file mode 100644 index 73aef1737..000000000 --- a/src/go/collectors/go.d.plugin/agent/discovery/sd/conffile.go +++ /dev/null @@ -1,69 +0,0 @@ -// SPDX-License-Identifier: GPL-3.0-or-later - -package sd - -import ( - "context" - "os" - - "github.com/netdata/netdata/go/go.d.plugin/logger" - "github.com/netdata/netdata/go/go.d.plugin/pkg/multipath" -) - -type confFile struct { - source string - content []byte -} - -func newConfFileReader(log *logger.Logger, dir multipath.MultiPath) *confFileReader { - return &confFileReader{ - Logger: log, - confDir: dir, - confChan: make(chan confFile), - } -} - -type confFileReader struct { - *logger.Logger - - confDir multipath.MultiPath - confChan chan confFile -} - -func (c *confFileReader) run(ctx context.Context) { - files, err := c.confDir.FindFiles(".conf") - if err != nil { - c.Error(err) - return - } - - if len(files) == 0 { - return - } - - var confFiles []confFile - - for _, file := range files { - bs, err := os.ReadFile(file) - if err != nil { - c.Error(err) - continue - } - confFiles = append(confFiles, confFile{ - source: file, - content: bs, - }) - } - - for _, conf := range confFiles { - select { - case <-ctx.Done(): - case c.confChan <- conf: - } - } - -} - -func (c *confFileReader) configs() chan confFile { - return c.confChan -} -- cgit v1.2.3