From b0b07ee70e053d2593066bc2df0ed83cb2aba919 Mon Sep 17 00:00:00 2001 From: Thomas Roehl Date: Tue, 25 Jan 2022 15:33:02 +0100 Subject: [PATCH] Fix Infiniband collector --- collectors/infinibandMetric.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/collectors/infinibandMetric.go b/collectors/infinibandMetric.go index 7b0e9dc..af4e579 100644 --- a/collectors/infinibandMetric.go +++ b/collectors/infinibandMetric.go @@ -173,9 +173,9 @@ func (m *InfinibandCollector) doPerfQuery(cmd string, dev string, lid string, po lv := strings.Fields(line) v, err := strconv.ParseFloat(lv[1], 64) if err == nil { - y, err := lp.New("ib_recv_pkts", tags, map[string]interface{}{"value": float64(v)}, time.Now()) + y, err := lp.New("ib_recv_pkts", tags, m.meta, map[string]interface{}{"value": float64(v)}, time.Now()) if err == nil { - *out = append(*out, y) + output <- y } } } @@ -183,9 +183,9 @@ func (m *InfinibandCollector) doPerfQuery(cmd string, dev string, lid string, po lv := strings.Fields(line) v, err := strconv.ParseFloat(lv[1], 64) if err == nil { - y, err := lp.New("ib_xmit_pkts", tags, map[string]interface{}{"value": float64(v)}, time.Now()) + y, err := lp.New("ib_xmit_pkts", tags, m.meta, map[string]interface{}{"value": float64(v)}, time.Now()) if err == nil { - *out = append(*out, y) + output <- y } } }