1 files changed, 69 insertions, 0 deletions
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
new file mode 100644
index 000000000..73aef1737
--- /dev/null
+++ b/src/go/collectors/go.d.plugin/agent/discovery/sd/conffile.go
@@ -0,0 +1,69 @@
+// 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
+}