From b5f8ee61a7f7e9bd291dd26b0585d03eb686c941 Mon Sep 17 00:00:00 2001
From: Daniel Baumann <daniel.baumann@progress-linux.org>
Date: Sun, 5 May 2024 13:19:16 +0200
Subject: Adding upstream version 1.46.3.

Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>
---
 .../go.d.plugin/agent/discovery/sd/conffile.go     | 69 ++++++++++++++++++++++
 1 file changed, 69 insertions(+)
 create 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
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
+}
-- 
cgit v1.2.3