From e8b2bbdae1a4087a5ad47c9b265828757e279eba Mon Sep 17 00:00:00 2001 From: Thomas Roehl Date: Wed, 12 May 2021 17:45:41 +0200 Subject: [PATCH] Fix format for cpustat collector --- collectors/cpustatMetric.go | 70 ++++++++++++++++++------------------- 1 file changed, 35 insertions(+), 35 deletions(-) diff --git a/collectors/cpustatMetric.go b/collectors/cpustatMetric.go index ea498d9..4bbb0ff 100644 --- a/collectors/cpustatMetric.go +++ b/collectors/cpustatMetric.go @@ -19,27 +19,27 @@ func (m *CpustatCollector) Init() { } func ParseStatLine(line string, out map[string]interface{}) { - ls := strings.Fields(line) - user, _ := strconv.ParseInt(ls[1], 0, 64) - out["cpu_user"] = float64(user) - nice, _ := strconv.ParseInt(ls[2], 0, 64) - out["cpu_nice"] = float64(nice) - system, _ := strconv.ParseInt(ls[3], 0, 64) - out["cpu_system"] = float64(system) - idle, _ := strconv.ParseInt(ls[4], 0, 64) - out["cpu_idle"] = float64(idle) - iowait, _ := strconv.ParseInt(ls[5], 0, 64) - out["cpu_iowait"] = float64(iowait) - irq, _ := strconv.ParseInt(ls[6], 0, 64) - out["cpu_irq"] = float64(irq) - softirq, _ := strconv.ParseInt(ls[7], 0, 64) - out["cpu_softirq"] = float64(softirq) - steal, _ := strconv.ParseInt(ls[8], 0, 64) - out["cpu_steal"] = float64(steal) - guest, _ := strconv.ParseInt(ls[9], 0, 64) - out["cpu_guest"] = float64(guest) - guest_nice, _ := strconv.ParseInt(ls[10], 0, 64) - out["cpu_guest_nice"] = float64(guest_nice) + ls := strings.Fields(line) + user, _ := strconv.ParseInt(ls[1], 0, 64) + out["cpu_user"] = float64(user) + nice, _ := strconv.ParseInt(ls[2], 0, 64) + out["cpu_nice"] = float64(nice) + system, _ := strconv.ParseInt(ls[3], 0, 64) + out["cpu_system"] = float64(system) + idle, _ := strconv.ParseInt(ls[4], 0, 64) + out["cpu_idle"] = float64(idle) + iowait, _ := strconv.ParseInt(ls[5], 0, 64) + out["cpu_iowait"] = float64(iowait) + irq, _ := strconv.ParseInt(ls[6], 0, 64) + out["cpu_irq"] = float64(irq) + softirq, _ := strconv.ParseInt(ls[7], 0, 64) + out["cpu_softirq"] = float64(softirq) + steal, _ := strconv.ParseInt(ls[8], 0, 64) + out["cpu_steal"] = float64(steal) + guest, _ := strconv.ParseInt(ls[9], 0, 64) + out["cpu_guest"] = float64(guest) + guest_nice, _ := strconv.ParseInt(ls[10], 0, 64) + out["cpu_guest_nice"] = float64(guest_nice) } func (m *CpustatCollector) Read(interval time.Duration) { @@ -49,20 +49,20 @@ func (m *CpustatCollector) Read(interval time.Duration) { return } - ll := strings.Split(string(buffer), "\n") - for _, line := range ll { - if (len(line) == 0) { - continue - } - ls := strings.Fields(line) - if (strings.Compare(ls[0], "cpu") == 0) { - ParseStatLine(line, m.node) - } else if (strings.HasPrefix(ls[0], "cpu")) { - cpustr := strings.TrimLeft(ls[0], "cpu") - cpu, _ := strconv.Atoi(cpustr) - ParseStatLine(line, m.cpus[cpu]) - } - } + ll := strings.Split(string(buffer), "\n") + for _, line := range ll { + if len(line) == 0 { + continue + } + ls := strings.Fields(line) + if strings.Compare(ls[0], "cpu") == 0 { + ParseStatLine(line, m.node) + } else if strings.HasPrefix(ls[0], "cpu") { + cpustr := strings.TrimLeft(ls[0], "cpu") + cpu, _ := strconv.Atoi(cpustr) + ParseStatLine(line, m.cpus[cpu]) + } + } } func (m *CpustatCollector) Close() {