diff --git a/pkg/monitoring/monitoring.go b/pkg/monitoring/monitoring.go index 1df212e1..ff528200 100644 --- a/pkg/monitoring/monitoring.go +++ b/pkg/monitoring/monitoring.go @@ -73,6 +73,10 @@ func (sm *ServerMonitoring) Shutdown(ctx context.Context) error { return sm.server.Shutdown(ctx) } +func (sm *ServerMonitoring) String() string { + return fmt.Sprintf("monitoring::%s:%d", sm.cfg.URLPrefix, sm.cfg.Port) +} + func validate(conf *monitoring.ServerMonitoringConfig) monitoring.ServerMonitoringConfig { if conf.Port == 0 { conf.Port = 6365 diff --git a/pkg/worker/worker.go b/pkg/worker/worker.go index 2661b5d3..5ea942ba 100644 --- a/pkg/worker/worker.go +++ b/pkg/worker/worker.go @@ -49,7 +49,7 @@ func (wrk *Worker) init() { } func (wrk *Worker) startModules() { - glog.Info(wrk.servers) + glog.Info("[worker] active modules: ", wrk.servers) for _, s := range wrk.servers { s := s go func() {