diff --git a/probe/probe.go b/probe/probe.go index 90f92d9..b707725 100644 --- a/probe/probe.go +++ b/probe/probe.go @@ -12,6 +12,7 @@ import ( oopccd "git.loafle.net/overflow/overflow_probes/client/central/data" oopccp "git.loafle.net/overflow/overflow_probes/client/central/probe" oopca "git.loafle.net/overflow/overflow_probes/commons/annotation" + oops "git.loafle.net/overflow/overflow_probes/service" ) func New() ProbeManager { @@ -45,14 +46,14 @@ func (pm *probeManagers) Start() error { } cdr.RegisterResource("CentralClients", centralClients) + oops.InitService() + services := cdr.GetInstancesByAnnotationName(oopca.ServiceTag) for _, s := range services { probeRPCRegistry.RegisterService(s, "") } - // logging.Logger().Debug(fmt.Sprintf("%v", centralService.CentralClients)) - if err := centralProbeClient.Connect(); nil != err { return err }