1 files changed, 46 insertions, 0 deletions
diff --git a/src/go/collectors/go.d.plugin/modules/windows/collect_collector.go b/src/go/collectors/go.d.plugin/modules/windows/collect_collector.go
new file mode 100644
index 000000000..6950ff575
--- /dev/null
+++ b/src/go/collectors/go.d.plugin/modules/windows/collect_collector.go
@@ -0,0 +1,46 @@
+// SPDX-License-Identifier: GPL-3.0-or-later
+
+package windows
+
+import (
+	"github.com/netdata/netdata/go/go.d.plugin/pkg/prometheus"
+)
+
+const (
+	metricCollectorDuration = "windows_exporter_collector_duration_seconds"
+	metricCollectorSuccess  = "windows_exporter_collector_success"
+)
+
+func (w *Windows) collectCollector(mx map[string]int64, pms prometheus.Series) {
+	seen := make(map[string]bool)
+	px := "collector_"
+	for _, pm := range pms.FindByName(metricCollectorDuration) {
+		if name := pm.Labels.Get("collector"); name != "" {
+			seen[name] = true
+			mx[px+name+"_duration"] = int64(pm.Value * precision)
+		}
+	}
+	for _, pm := range pms.FindByName(metricCollectorSuccess) {
+		if name := pm.Labels.Get("collector"); name != "" {
+			seen[name] = true
+			if pm.Value == 1 {
+				mx[px+name+"_status_success"], mx[px+name+"_status_fail"] = 1, 0
+			} else {
+				mx[px+name+"_status_success"], mx[px+name+"_status_fail"] = 0, 1
+			}
+		}
+	}
+
+	for name := range seen {
+		if !w.cache.collectors[name] {
+			w.cache.collectors[name] = true
+			w.addCollectorCharts(name)
+		}
+	}
+	for name := range w.cache.collectors {
+		if !seen[name] {
+			delete(w.cache.collectors, name)
+			w.removeCollectorCharts(name)
+		}
+	}
+}