|
|
|
@ -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(),
|
|
|
|
|