Merge branch 'main' into elasticsearch-opensearch-authenticator

Author: SoumyaRaikwar

internal/storage/v1/elasticsearch/factory_test.go

@@ -318,8 +318,15 @@ func TestESStorageFactoryWithConfig(t *testing.T) {
 
 func TestESStorageFactoryWithConfigError(t *testing.T) {
 	t.Parallel()
+	server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
+		if r.URL.Path == "/" {
+			w.WriteHeader(http.StatusInternalServerError)
+			return
+		}
+	}))
+	defer server.Close()
 	cfg := escfg.Configuration{
-		Servers:            []string{"http://invalid-host-name:65535"},
+		Servers:            []string{server.URL},
 		DisableHealthCheck: true,
 		LogLevel:           "error",
 	}

internal/storage/v1/elasticsearch/factoryv1_test.go

@@ -103,6 +103,12 @@ func TestArchiveFactory(t *testing.T) {
 
 func TestFactoryInitializeErr(t *testing.T) {
 	t.Parallel()
+	server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
+		if r.URL.Path == "/" {
+			w.WriteHeader(http.StatusInternalServerError)
+		}
+	}))
+	defer server.Close()
 	tests := []struct {
 		name        string
 		factory     *Factory
@@ -116,7 +122,7 @@ func TestFactoryInitializeErr(t *testing.T) {
 		{
 			name: "server error",
 			factory: &Factory{Options: &Options{Config: namespaceConfig{Configuration: escfg.Configuration{
-				Servers:            []string{"http://invalid-host-name:9200"},
+				Servers:            []string{server.URL},
 				DisableHealthCheck: true,
 			}}}},
 			expectedErr: "failed to create Elasticsearch client",