From 912da395c9bcf63ebf8821c4963fe461d0b116e1 Mon Sep 17 00:00:00 2001 From: wangchuxiao Date: Fri, 9 Sep 2022 15:29:22 +0800 Subject: [PATCH] merge --- internal/msg_transfer/logic/persistent_msg_handler.go | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/internal/msg_transfer/logic/persistent_msg_handler.go b/internal/msg_transfer/logic/persistent_msg_handler.go index 817b3edb9..61172128e 100644 --- a/internal/msg_transfer/logic/persistent_msg_handler.go +++ b/internal/msg_transfer/logic/persistent_msg_handler.go @@ -23,7 +23,11 @@ import ( ) var ( - msgInsertMysqlProcessed prometheus.Counter + // msgInsertMysqlProcessed perometheus.Countr + msgInsertMysqlProcessed = promauto.NewCounter(prometheus.CounterOpts{ + Name: "insert_mysql_msg_total", + Help: "The total number of msg insert mysql events", + }) ) type PersistentConsumerHandler struct { @@ -42,7 +46,6 @@ func (pc *PersistentConsumerHandler) Init() { Name: "insert_mysql_msg_total", Help: "The total number of msg insert mysql events", }) - prometheus.MustRegister(msgInsertMysqlProcessed) } }