netdata/netdata

// 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)
        }
    }
}