diff --git a/client/consul/sync.go b/client/consul/sync.go index 3ecc3e6e4..446385f4f 100644 --- a/client/consul/sync.go +++ b/client/consul/sync.go @@ -268,8 +268,8 @@ func (c *ConsulService) deregisterCheck(ID string) error { return c.client.Agent().CheckDeregister(ID) } -// SyncWithConsul triggers periodic syncing of services and checks with Consul -func (c *ConsulService) SyncWithConsul() { +// PeriodicSync triggers periodic syncing of services and checks with Consul +func (c *ConsulService) PeriodicSync() { sync := time.After(syncInterval) for { select { diff --git a/client/driver/executor/executor.go b/client/driver/executor/executor.go index 5870c0b96..d9929aed7 100644 --- a/client/driver/executor/executor.go +++ b/client/driver/executor/executor.go @@ -359,7 +359,7 @@ func (e *UniversalExecutor) RegisterServices() error { e.consulService = cs } err := e.consulService.SyncTask(e.ctx.Task) - go e.consulService.SyncWithConsul() + go e.consulService.PeriodicSync() return err }