lijian 2 anni fa
parent
commit
138484e541
1 ha cambiato i file con 2 aggiunte e 2 eliminazioni
  1. 2 2
      services/mqttaccess/main.go

+ 2 - 2
services/mqttaccess/main.go

@@ -7,7 +7,7 @@ import (
 )
 
 var deviceOnlineCount prometheus.Gauge
-var deviceMessageCount prometheus.CounterVec
+var deviceMessageCount *prometheus.CounterVec
 
 func main() {
 	// init server
@@ -52,7 +52,7 @@ func main() {
 
 	server.RegisterMetric(deviceOnlineMetric, recvMessageCount)
 	deviceOnlineCount = deviceOnlineMetric.MetricCollector.(prometheus.Gauge)
-	deviceMessageCount = recvMessageCount.MetricCollector.(prometheus.CounterVec)
+	deviceMessageCount = recvMessageCount.MetricCollector.(*prometheus.CounterVec)
 	// start to run
 	err = server.Run()
 	if err != nil {