|
|
@@ -40,23 +40,23 @@ func main() {
|
|
|
return
|
|
|
}
|
|
|
|
|
|
- //deviceOnlineMetric := &server.Metric{
|
|
|
- // ID: "device_online_count",
|
|
|
- // Name: "device_online_count",
|
|
|
- // Description: "MQTT Device Online Count",
|
|
|
- // Type: "gauge",
|
|
|
- //}
|
|
|
- //recvMessageCount := &server.Metric{
|
|
|
- // ID: "device_message_total",
|
|
|
- // Name: "device_message_total",
|
|
|
- // Description: "device report message total count",
|
|
|
- // Type: "counter_vec",
|
|
|
- // Args: []string{"device_code"},
|
|
|
- //}
|
|
|
- //
|
|
|
- //server.RegisterMetric(deviceOnlineMetric, recvMessageCount)
|
|
|
- //deviceOnlineCount = deviceOnlineMetric.MetricCollector.(prometheus.Gauge)
|
|
|
- //deviceMessageCount = recvMessageCount.MetricCollector.(*prometheus.CounterVec)
|
|
|
+ deviceOnlineMetric := &server.Metric{
|
|
|
+ ID: "device_online_count",
|
|
|
+ Name: "device_online_count",
|
|
|
+ Description: "MQTT Device Online Count",
|
|
|
+ Type: "gauge",
|
|
|
+ }
|
|
|
+ recvMessageCount := &server.Metric{
|
|
|
+ ID: "device_message_total",
|
|
|
+ Name: "device_message_total",
|
|
|
+ Description: "device report message total count",
|
|
|
+ Type: "counter_vec",
|
|
|
+ Args: []string{"device_code"},
|
|
|
+ }
|
|
|
+
|
|
|
+ server.RegisterMetric(deviceOnlineMetric, recvMessageCount)
|
|
|
+ deviceOnlineCount = deviceOnlineMetric.MetricCollector.(prometheus.Gauge)
|
|
|
+ deviceMessageCount = recvMessageCount.MetricCollector.(*prometheus.CounterVec)
|
|
|
|
|
|
go func() {
|
|
|
pprofPort := "6060"
|
liuxiulin