Return on consul watcher errors

rapid7 · Jun 16, 2018 · 4fd53ba · 4fd53ba
1 parent 3c51e63
commit 4fd53ba
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/watchers/consul/consul.go b/watchers/consul/consul.go
@@ -66,13 +66,15 @@ func Sync(t time.Time) {
 	client, err := api.NewClient(consulConfig)
 	if err != nil {
 		log.Errorf("Consul error: %v\n", err)
+		return
 	}
 
 	catalog := client.Catalog()
 	qo := api.QueryOptions{}
 	services, _, err := catalog.Services(&qo)
 	if err != nil {
 		log.Errorf("Catalog/services error: %v", err)
+		return
 	}
 
 	var wg sync.WaitGroup
@@ -110,6 +112,7 @@ func getServiceHealth(key string, client *api.Client, qo api.QueryOptions, m *sy
 	sh, _, err := h.Service(key, "", true, &qo)
 	if err != nil {
 		log.Errorf("Failed to find service: %v", err)
+		return
 	}
 
 	for _, element := range sh {