MLE-14506: removed scaleDown test as deletion of node from ML cluster is not needed to be tested (#248)

Author: barkhachoithani

test/e2e/scaling_test.go

@@ -129,119 +129,3 @@ func TestHelmScaleUp(t *testing.T) {
 		t.Errorf("Incorrect number of MarkLogic hosts")
 	}
 }
-
-func TestHelmScaleDown(t *testing.T) {
-	// Path to the helm chart we will test
-	helmChartPath, e := filepath.Abs("../../charts")
-	if e != nil {
-		t.Fatalf(e.Error())
-	}
-	imageRepo, repoPres := os.LookupEnv("dockerRepository")
-	imageTag, tagPres := os.LookupEnv("dockerVersion")
-	username := "admin"
-	password := "admin"
-
-	if !repoPres {
-		imageRepo = "marklogicdb/marklogic-db"
-		t.Logf("No imageRepo variable present, setting to default value: " + imageRepo)
-	}
-
-	if !tagPres {
-		imageTag = "latest"
-		t.Logf("No imageTag variable present, setting to default value: " + imageTag)
-	}
-
-	namespaceName := "ml-" + strings.ToLower(random.UniqueId())
-	kubectlOptions := k8s.NewKubectlOptions("", "", namespaceName)
-	options := &helm.Options{
-		KubectlOptions: kubectlOptions,
-		SetValues: map[string]string{
-			"persistence.enabled":   "false",
-			"replicaCount":          "2",
-			"image.repository":      imageRepo,
-			"image.tag":             imageTag,
-			"auth.adminUsername":    username,
-			"auth.adminPassword":    password,
-			"logCollection.enabled": "false",
-		},
-	}
-
-	t.Logf("====Creating namespace: " + namespaceName)
-	k8s.CreateNamespace(t, kubectlOptions, namespaceName)
-	defer t.Logf("====Deleting namespace: " + namespaceName)
-	defer k8s.DeleteNamespace(t, kubectlOptions, namespaceName)
-
-	t.Logf("====Installing Helm Chart")
-	releaseName := "test-scale-down"
-	helm.Install(t, options, helmChartPath, releaseName)
-
-	podName1 := releaseName + "-1"
-
-	// wait until the pod is in Ready status
-	k8s.WaitUntilPodAvailable(t, kubectlOptions, podName1, 15, 20*time.Second)
-
-	newOptions := &helm.Options{
-		KubectlOptions: kubectlOptions,
-		SetValues: map[string]string{
-			"persistence.enabled":   "false",
-			"replicaCount":          "1",
-			"image.repository":      imageRepo,
-			"image.tag":             imageTag,
-			"logCollection.enabled": "false",
-		},
-	}
-
-	t.Logf("====Upgrading Helm Chart")
-	helm.Upgrade(t, newOptions, helmChartPath, releaseName)
-
-	time.Sleep(20 * time.Second)
-
-	podName0 := releaseName + "-0"
-
-	tunnel := k8s.NewTunnel(
-		kubectlOptions, k8s.ResourceTypePod, podName0, 8002, 8002)
-	defer tunnel.Close()
-	tunnel.ForwardPort(t)
-
-	numOfHostsOffline := 1
-	client := req.C()
-	_, err := client.R().
-		SetDigestAuth(username, password).
-		SetRetryCount(3).
-		SetRetryFixedInterval(10 * time.Second).
-		AddRetryCondition(func(resp *req.Response, err error) bool {
-			if resp == nil || err != nil {
-				t.Logf("error in AddRetryCondition: %s", err.Error())
-				return true
-			}
-			if resp.Response == nil {
-				t.Log("Could not get the Response Object, Retrying...")
-				return true
-			}
-			if resp.Body == nil {
-				t.Log("Could not get the body for the response, Retrying...")
-				return true
-			}
-			body, err := io.ReadAll(resp.Body)
-			if body == nil || err != nil {
-				t.Logf("error in read response body: %s", err.Error())
-				return true
-			}
-			totalOfflineHosts := gjson.Get(string(body), `host-status-list.status-list-summary.total-hosts-offline.value`)
-			numOfHostsOffline = int(totalOfflineHosts.Num)
-			if numOfHostsOffline != 1 {
-				t.Log("Waiting for second host to shutdown")
-			}
-			return numOfHostsOffline != 1
-		}).
-		Get("http://localhost:8002/manage/v2/hosts?view=status&format=json")
-
-	if err != nil {
-		t.Fatalf(err.Error())
-	}
-
-	// verify total number of hosts on the clsuter after scaling up
-	if numOfHostsOffline != 1 {
-		t.Errorf("Incorrect number of offline hosts")
-	}
-}