diff --git a/modules/elastic/api/test_connection.go b/modules/elastic/api/test_connection.go index 2778445b..5d79f9ee 100644 --- a/modules/elastic/api/test_connection.go +++ b/modules/elastic/api/test_connection.go @@ -117,7 +117,8 @@ func (h TestAPI) HandleTestConnectionAction(w http.ResponseWriter, req *http.Req freq.SetBasicAuth(config.BasicAuth.Username, config.BasicAuth.Password.Get()) } - err = api.GetFastHttpClient("elasticsearch_test_connection").DoTimeout(freq, fres, 10*time.Second) + const testClientName = "elasticsearch_test_connection" + err = api.GetFastHttpClient(testClientName).DoTimeout(freq, fres, 10*time.Second) if err != nil { panic(err) @@ -145,7 +146,7 @@ func (h TestAPI) HandleTestConnectionAction(w http.ResponseWriter, req *http.Req //fetch cluster health info freq.SetRequestURI(fmt.Sprintf("%s/_cluster/health", config.Endpoint)) fres.Reset() - err = api.GetFastHttpClient().Do(freq, fres) + err = api.GetFastHttpClient(testClientName).Do(freq, fres) if err != nil { resBody["error"] = fmt.Sprintf("error on get cluster health: %v", err) h.WriteJSON(w, resBody, http.StatusInternalServerError)