1 files changed, 59 insertions, 0 deletions
diff --git a/src/go/plugin/go.d/modules/filecheck/collect_files.go b/src/go/plugin/go.d/modules/filecheck/collect_files.go
new file mode 100644
index 000000000..4c465c111
--- /dev/null
+++ b/src/go/plugin/go.d/modules/filecheck/collect_files.go
@@ -0,0 +1,59 @@
+// SPDX-License-Identifier: GPL-3.0-or-later
+
+package filecheck
+
+import (
+	"fmt"
+	"os"
+	"time"
+)
+
+func (f *Filecheck) collectFiles(mx map[string]int64) {
+	now := time.Now()
+
+	if f.isTimeToDiscoverFiles(now) {
+		f.lastDiscFilesTime = now
+		f.curFiles = f.discoverFiles()
+	}
+
+	var infos []*statInfo
+
+	for _, file := range f.curFiles {
+		si := getStatInfo(file)
+
+		infos = append(infos, si)
+
+		f.collectFile(mx, si, now)
+	}
+
+	f.updateFileCharts(infos)
+}
+
+func (f *Filecheck) collectFile(mx map[string]int64, si *statInfo, now time.Time) {
+	px := fmt.Sprintf("file_%s_", si.path)
+
+	mx[px+"existence_status_exist"] = 0
+	mx[px+"existence_status_not_exist"] = 0
+	if !si.exists {
+		mx[px+"existence_status_not_exist"] = 1
+	} else {
+		mx[px+"existence_status_exist"] = 1
+	}
+
+	if si.fi == nil || !si.fi.Mode().IsRegular() {
+		return
+	}
+
+	mx[px+"mtime_ago"] = int64(now.Sub(si.fi.ModTime()).Seconds())
+	mx[px+"size_bytes"] = si.fi.Size()
+}
+
+func (f *Filecheck) discoverFiles() (files []string) {
+	return discoverFilesOrDirs(f.Files.Include, func(absPath string, fi os.FileInfo) bool {
+		return fi.Mode().IsRegular() && !f.filesFilter.MatchString(absPath)
+	})
+}
+
+func (f *Filecheck) isTimeToDiscoverFiles(now time.Time) bool {
+	return now.After(f.lastDiscFilesTime.Add(f.DiscoveryEvery.Duration()))
+}