diff --git a/internal/msgtransfer/init.go b/internal/msgtransfer/init.go index 4ce015543..830e0b1da 100644 --- a/internal/msgtransfer/init.go +++ b/internal/msgtransfer/init.go @@ -20,6 +20,7 @@ import ( "log" "net/http" "sync" + "time" "github.com/OpenIMSDK/tools/mw" "github.com/prometheus/client_golang/prometheus" @@ -119,6 +120,10 @@ 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(),