Implement metrics for concentratord backend.

Author: brocaar

internal/backend/concentratord/concentratord.go

@@ -146,6 +146,8 @@ func (b *Backend) SendDownlinkFrame(pl gw.DownlinkFrame) error {
 
 	b.downlinkTXAckChan <- ack
 
+	commandCounter("down").Inc()
+
 	return nil
 }
 
@@ -227,6 +229,8 @@ func (b *Backend) eventLoop() {
 				"event": string(msg.Frames[0]),
 			}).Error("backend/concentratord: handle event error")
 		}
+
+		eventCounter(string(msg.Frames[0])).Inc()
 	}
 }
 

internal/backend/concentratord/metrics.go

@@ -0,0 +1,26 @@
+package concentratord
+
+import (
+	"github.com/prometheus/client_golang/prometheus"
+	"github.com/prometheus/client_golang/prometheus/promauto"
+)
+
+var (
+	ec = promauto.NewCounterVec(prometheus.CounterOpts{
+		Name: "backend_concentratord_event_count",
+		Help: "The number of received events (per type)",
+	}, []string{"event"})
+
+	cc = promauto.NewCounterVec(prometheus.CounterOpts{
+		Name: "backend_concentratord_command_count",
+		Help: "The number of received commands (per type)",
+	}, []string{"command"})
+)
+
+func eventCounter(typ string) prometheus.Counter {
+	return ec.With(prometheus.Labels{"event": typ})
+}
+
+func commandCounter(typ string) prometheus.Counter {
+	return cc.With(prometheus.Labels{"command": typ})
+}