diff --git a/internal/msgtransfer/init.go b/internal/msgtransfer/init.go index c3e5b8352..c18186fa8 100644 --- a/internal/msgtransfer/init.go +++ b/internal/msgtransfer/init.go @@ -118,13 +118,15 @@ func (m *MsgTransfer) Start(prometheusPort int) error { return err }*/ //////////////////////////// - reg := prometheus.NewRegistry() - reg.MustRegister( - collectors.NewGoCollector(), - ) - reg.MustRegister(prom_metrics.GetGrpcCusMetrics("Transfer")...) - http.Handle("/metrics", promhttp.HandlerFor(reg, promhttp.HandlerOpts{Registry: reg})) - log.Fatal(http.ListenAndServe(fmt.Sprintf(":%d", prometheusPort), nil)) + if config.Config.Prometheus.Enable { + reg := prometheus.NewRegistry() + reg.MustRegister( + collectors.NewGoCollector(), + ) + reg.MustRegister(prom_metrics.GetGrpcCusMetrics("Transfer")...) + http.Handle("/metrics", promhttp.HandlerFor(reg, promhttp.HandlerOpts{Registry: reg})) + log.Fatal(http.ListenAndServe(fmt.Sprintf(":%d", prometheusPort), nil)) + } //////////////////////////////////////// wg.Wait() return nil