diff --git a/src/server/engine/engine.go b/src/server/engine/engine.go index dace3f26ff315fde3e74f62e7cc730be94044398..de36bafd6453ccb4b22595a5cee35a67e010616f 100644 --- a/src/server/engine/engine.go +++ b/src/server/engine/engine.go @@ -54,6 +54,6 @@ func reportQueueSize() { for { time.Sleep(time.Second) - promstat.GaugeAlertQueueSize.WithLabelValues().Set(float64(EventQueue.Len())) + promstat.GaugeAlertQueueSize.Set(float64(EventQueue.Len())) } } diff --git a/src/server/stat/stat.go b/src/server/stat/stat.go index 75a6b540ce5b36e0dce3ed325fb1d3ca058d07ce..0f75abb6fb3b3ccbbb72cd2869d75e1d9e9ed0f4 100644 --- a/src/server/stat/stat.go +++ b/src/server/stat/stat.go @@ -43,12 +43,12 @@ var ( }, []string{"cluster"}) // 内存中的告警事件队列的长度 - GaugeAlertQueueSize = prometheus.NewGaugeVec(prometheus.GaugeOpts{ + GaugeAlertQueueSize = prometheus.NewGauge(prometheus.GaugeOpts{ Namespace: namespace, Subsystem: subsystem, Name: "alert_queue_size", Help: "The size of alert queue.", - }, []string{}) + }) // 数据转发队列,各个队列的长度 GaugeSampleQueueSize = prometheus.NewGaugeVec(prometheus.GaugeOpts{