Improve ES health checking

Signed-off-by: Raul Sevilla <[email protected]>
rsevilla87 · Sep 22, 2020 · e41f971 · e41f971
1 parent 1a5123f
commit e41f971
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/pkg/indexers/elastic.go b/pkg/indexers/elastic.go
@@ -52,9 +52,9 @@ func (esIndexer *Elastic) new(esConfig config.IndexerConfig) {
 	if err != nil {
 		log.Errorf("Error creating the ES client: %s", err)
 	}
-	r, err := ESClient.Ping()
+	r, err := ESClient.Cluster.Health()
 	if err != nil {
-		log.Fatalf("ES connection error: %s", err)
+		log.Fatalf("ES health check failed: %s", err)
 	}
 	if r.StatusCode != 200 {
 		log.Fatalf("Unexpected ES status code: %d", r.StatusCode)