From d2cd8ed86aa07aeab2f9a997869777dbe3b974bb Mon Sep 17 00:00:00 2001 From: crusader Date: Thu, 15 Mar 2018 23:40:27 +0900 Subject: [PATCH] ing --- probe/probe.go | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) 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 }