report sample channel size

efaafe6e · Ulric Qin · 725c0d66 · efaafe6e
隐藏空白更改
内联并排

Showing with 6 addition and 3 deletion

src/server/writer/writer.go src/server/writer/writer.go +6 -3

未找到文件。
--- a/src/server/writer/writer.go
+++ b/src/server/writer/writer.go
@@ -232,8 +232,11 @@ func Init(opts []config.WriterOptions, globalOpt config.WriterGlobalOpt) error {
 }

 func reportChanSize() {
-	for i, c := range Writers.chans {
-		size := len(c)
-		promstat.GaugeSampleQueueSize.WithLabelValues(config.C.ClusterName, fmt.Sprint(i)).Set(float64(size))
+	for {
+		time.Sleep(time.Second * 3)
+		for i, c := range Writers.chans {
+			size := len(c)
+			promstat.GaugeSampleQueueSize.WithLabelValues(config.C.ClusterName, fmt.Sprint(i)).Set(float64(size))
+		}
 	}
 }