From e6a6218f6aa34d612c9d5a3c2fd3d3731d6f011c Mon Sep 17 00:00:00 2001 From: "lin.huang" Date: Fri, 24 Nov 2023 17:31:35 +0800 Subject: [PATCH] del:del test code --- internal/msgtransfer/init.go | 12 +++--------- 1 file changed, 3 insertions(+), 9 deletions(-) diff --git a/internal/msgtransfer/init.go b/internal/msgtransfer/init.go index 830e0b1da..8436317ee 100644 --- a/internal/msgtransfer/init.go +++ b/internal/msgtransfer/init.go @@ -17,17 +17,15 @@ package msgtransfer import ( "errors" "fmt" - "log" - "net/http" - "sync" - "time" - "github.com/OpenIMSDK/tools/mw" "github.com/prometheus/client_golang/prometheus" "github.com/prometheus/client_golang/prometheus/collectors" "github.com/prometheus/client_golang/prometheus/promhttp" "google.golang.org/grpc" "google.golang.org/grpc/credentials/insecure" + "log" + "net/http" + "sync" "github.com/openimsdk/open-im-server/v3/pkg/common/config" "github.com/openimsdk/open-im-server/v3/pkg/common/db/cache" @@ -120,10 +118,6 @@ func (m *MsgTransfer) Start(prometheusPort int) error { }*/ //////////////////////////// if config.Config.Prometheus.Enable { - go func() { - time.Sleep(7 * time.Minute) - prommetrics.MsgInsertRedisFailedCounter.Inc() - }() reg := prometheus.NewRegistry() reg.MustRegister( collectors.NewGoCollector(),