From 87d772a7d708fec12f48cd8adc0dedff6e1025da Mon Sep 17 00:00:00 2001 From: Daniel Baumann Date: Mon, 26 Aug 2024 10:15:20 +0200 Subject: Adding upstream version 1.47.0. Signed-off-by: Daniel Baumann --- .../go.d.plugin/modules/windows/collect.go | 163 --------------------- 1 file changed, 163 deletions(-) delete mode 100644 src/go/collectors/go.d.plugin/modules/windows/collect.go (limited to 'src/go/collectors/go.d.plugin/modules/windows/collect.go') diff --git a/src/go/collectors/go.d.plugin/modules/windows/collect.go b/src/go/collectors/go.d.plugin/modules/windows/collect.go deleted file mode 100644 index b20b08c27..000000000 --- a/src/go/collectors/go.d.plugin/modules/windows/collect.go +++ /dev/null @@ -1,163 +0,0 @@ -// SPDX-License-Identifier: GPL-3.0-or-later - -package windows - -import ( - "github.com/netdata/netdata/go/go.d.plugin/pkg/prometheus" -) - -const precision = 1000 - -const ( - collectorAD = "ad" - collectorADCS = "adcs" - collectorADFS = "adfs" - collectorCPU = "cpu" - collectorMemory = "memory" - collectorNet = "net" - collectorLogicalDisk = "logical_disk" - collectorOS = "os" - collectorSystem = "system" - collectorLogon = "logon" - collectorThermalZone = "thermalzone" - collectorTCP = "tcp" - collectorIIS = "iis" - collectorMSSQL = "mssql" - collectorProcess = "process" - collectorService = "service" - collectorNetFrameworkCLRExceptions = "netframework_clrexceptions" - collectorNetFrameworkCLRInterop = "netframework_clrinterop" - collectorNetFrameworkCLRJIT = "netframework_clrjit" - collectorNetFrameworkCLRLoading = "netframework_clrloading" - collectorNetFrameworkCLRLocksAndThreads = "netframework_clrlocksandthreads" - collectorNetFrameworkCLRMemory = "netframework_clrmemory" - collectorNetFrameworkCLRRemoting = "netframework_clrremoting" - collectorNetFrameworkCLRSecurity = "netframework_clrsecurity" - collectorExchange = "exchange" - collectorHyperv = "hyperv" -) - -func (w *Windows) collect() (map[string]int64, error) { - pms, err := w.prom.ScrapeSeries() - if err != nil { - return nil, err - } - - mx := make(map[string]int64) - w.collectMetrics(mx, pms) - - if hasKey(mx, "os_visible_memory_bytes", "memory_available_bytes") { - mx["memory_used_bytes"] = 0 + - mx["os_visible_memory_bytes"] - - mx["memory_available_bytes"] - } - if hasKey(mx, "os_paging_limit_bytes", "os_paging_free_bytes") { - mx["os_paging_used_bytes"] = 0 + - mx["os_paging_limit_bytes"] - - mx["os_paging_free_bytes"] - } - if hasKey(mx, "os_visible_memory_bytes", "os_physical_memory_free_bytes") { - mx["os_visible_memory_used_bytes"] = 0 + - mx["os_visible_memory_bytes"] - - mx["os_physical_memory_free_bytes"] - } - if hasKey(mx, "memory_commit_limit", "memory_committed_bytes") { - mx["memory_not_committed_bytes"] = 0 + - mx["memory_commit_limit"] - - mx["memory_committed_bytes"] - } - if hasKey(mx, "memory_standby_cache_reserve_bytes", "memory_standby_cache_normal_priority_bytes", "memory_standby_cache_core_bytes") { - mx["memory_standby_cache_total"] = 0 + - mx["memory_standby_cache_reserve_bytes"] + - mx["memory_standby_cache_normal_priority_bytes"] + - mx["memory_standby_cache_core_bytes"] - } - if hasKey(mx, "memory_standby_cache_total", "memory_modified_page_list_bytes") { - mx["memory_cache_total"] = 0 + - mx["memory_standby_cache_total"] + - mx["memory_modified_page_list_bytes"] - } - - return mx, nil -} - -func (w *Windows) collectMetrics(mx map[string]int64, pms prometheus.Series) { - w.collectCollector(mx, pms) - for _, pm := range pms.FindByName(metricCollectorSuccess) { - if pm.Value == 0 { - continue - } - - switch pm.Labels.Get("collector") { - case collectorCPU: - w.collectCPU(mx, pms) - case collectorMemory: - w.collectMemory(mx, pms) - case collectorNet: - w.collectNet(mx, pms) - case collectorLogicalDisk: - w.collectLogicalDisk(mx, pms) - case collectorOS: - w.collectOS(mx, pms) - case collectorSystem: - w.collectSystem(mx, pms) - case collectorLogon: - w.collectLogon(mx, pms) - case collectorThermalZone: - w.collectThermalzone(mx, pms) - case collectorTCP: - w.collectTCP(mx, pms) - case collectorProcess: - w.collectProcess(mx, pms) - case collectorService: - w.collectService(mx, pms) - case collectorIIS: - w.collectIIS(mx, pms) - case collectorMSSQL: - w.collectMSSQL(mx, pms) - case collectorAD: - w.collectAD(mx, pms) - case collectorADCS: - w.collectADCS(mx, pms) - case collectorADFS: - w.collectADFS(mx, pms) - case collectorNetFrameworkCLRExceptions: - w.collectNetFrameworkCLRExceptions(mx, pms) - case collectorNetFrameworkCLRInterop: - w.collectNetFrameworkCLRInterop(mx, pms) - case collectorNetFrameworkCLRJIT: - w.collectNetFrameworkCLRJIT(mx, pms) - case collectorNetFrameworkCLRLoading: - w.collectNetFrameworkCLRLoading(mx, pms) - case collectorNetFrameworkCLRLocksAndThreads: - w.collectNetFrameworkCLRLocksAndThreads(mx, pms) - case collectorNetFrameworkCLRMemory: - w.collectNetFrameworkCLRMemory(mx, pms) - case collectorNetFrameworkCLRRemoting: - w.collectNetFrameworkCLRRemoting(mx, pms) - case collectorNetFrameworkCLRSecurity: - w.collectNetFrameworkCLRSecurity(mx, pms) - case collectorExchange: - w.collectExchange(mx, pms) - case collectorHyperv: - w.collectHyperv(mx, pms) - } - } -} - -func hasKey(mx map[string]int64, key string, keys ...string) bool { - _, ok := mx[key] - switch len(keys) { - case 0: - return ok - default: - return ok && hasKey(mx, keys[0], keys[1:]...) - } -} - -func boolToInt(v bool) int64 { - if v { - return 1 - } - return 0 -} -- cgit v1.2.3