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