util name fix

Author: rajguptavm

tests/e2e/k8testutil/util.go

@@ -7330,10 +7330,10 @@ func ExitHostMM(ctx context.Context, host *object.HostSystem, timeout int32) {
 }
 
 /*
-createStafeulSetAndVerifyPVAndPodNodeAffinty creates user specified statefulset and
+CreateStatefulSetAndVerifyPVAndPodNodeAffinty creates user specified statefulset and
 further checks the node and volumes affinities
 */
-func CreateStafeulSetAndVerifyPVAndPodNodeAffinty(ctx context.Context, client clientset.Interface,
+func CreateStatefulSetAndVerifyPVAndPodNodeAffinty(ctx context.Context, client clientset.Interface,
 	vs *config.E2eTestConfig, namespace string, parallelPodPolicy bool, replicas int32, nodeAffinityToSet bool,
 	allowedTopologies []v1.TopologySelectorLabelRequirement,
 	podAntiAffinityToSet bool, parallelStatefulSetCreation bool, modifyStsSpec bool,

tests/e2e/multiSvc/multi_svc_test.go

@@ -261,7 +261,7 @@ var _ = ginkgo.Describe("[csi-multi-svc] Multi-SVC", func() {
 				}
 
 				ginkgo.By("Create StatefulSet with 3 replicas with parallel pod management")
-				service, statefulset, err := k8testutil.CreateStafeulSetAndVerifyPVAndPodNodeAffinty(ctx, client,
+				service, statefulset, err := k8testutil.CreateStatefulSetAndVerifyPVAndPodNodeAffinty(ctx, client,
 					e2eTestConfig, namespace, true, 3, false, nil, false, false, true, "", nil, false,
 					storagePolicyNames[n])
 				gomega.Expect(err).NotTo(gomega.HaveOccurred())
@@ -272,14 +272,14 @@ var _ = ginkgo.Describe("[csi-multi-svc] Multi-SVC", func() {
 
 				framework.Logf("Scale up sts replica count to 5")
 				scaleUpReplicaCount = 5
-				err = k8testutil.ScaleUpStatefulSetPod(ctx, client, e2eTestConfig, statefulset, namespace, scaleUpReplicaCount,
-					true)
+				err = k8testutil.ScaleUpStatefulSetPod(ctx, client, e2eTestConfig, statefulset, namespace,
+					scaleUpReplicaCount, true)
 				gomega.Expect(err).NotTo(gomega.HaveOccurred())
 
 				framework.Logf("Scale down sts replica count to 1")
 				scaleDownReplicaCount = 1
-				err = k8testutil.ScaleDownStatefulSetPod(ctx, e2eTestConfig, client, statefulset, namespace, scaleDownReplicaCount,
-					true)
+				err = k8testutil.ScaleDownStatefulSetPod(ctx, e2eTestConfig, client, statefulset, namespace,
+					scaleDownReplicaCount, true)
 				gomega.Expect(err).NotTo(gomega.HaveOccurred())
 
 			}
@@ -319,7 +319,7 @@ var _ = ginkgo.Describe("[csi-multi-svc] Multi-SVC", func() {
 				}
 
 				ginkgo.By("Create StatefulSet with 3 replicas with parallel pod management")
-				service, statefulset, err := k8testutil.CreateStafeulSetAndVerifyPVAndPodNodeAffinty(ctx, client,
+				service, statefulset, err := k8testutil.CreateStatefulSetAndVerifyPVAndPodNodeAffinty(ctx, client,
 					e2eTestConfig, namespace, true, 3, false, nil, false, false, true, "", nil, false,
 					storagePolicyNames[i])
 				gomega.Expect(err).NotTo(gomega.HaveOccurred())
@@ -337,8 +337,8 @@ var _ = ginkgo.Describe("[csi-multi-svc] Multi-SVC", func() {
 				// scaling up/down sts created before password rotation
 				framework.Logf("Scale up sts replica count to 5")
 				scaleUpReplicaCount = 5
-				err = k8testutil.ScaleUpStatefulSetPod(ctx, client, e2eTestConfig, statefulset, namespace, scaleUpReplicaCount,
-					true)
+				err = k8testutil.ScaleUpStatefulSetPod(ctx, client, e2eTestConfig, statefulset, namespace,
+					scaleUpReplicaCount, true)
 				gomega.Expect(err).NotTo(gomega.HaveOccurred())
 
 				framework.Logf("Scale down sts replica count to 1")
@@ -361,7 +361,8 @@ var _ = ginkgo.Describe("[csi-multi-svc] Multi-SVC", func() {
 				var volHandle string
 				pvclaims = append(pvclaims, pvclaim)
 				ginkgo.By("Waiting for pvc to be in bound state")
-				persistentvolumes, err := fpv.WaitForPVClaimBoundPhase(ctx, client, pvclaims, framework.ClaimProvisionTimeout)
+				persistentvolumes, err := fpv.WaitForPVClaimBoundPhase(ctx, client, pvclaims,
+					framework.ClaimProvisionTimeout)
 				gomega.Expect(err).NotTo(gomega.HaveOccurred())
 				pv := persistentvolumes[0]
 				volHandle = pv.Spec.CSI.VolumeHandle
@@ -727,7 +728,7 @@ var _ = ginkgo.Describe("[csi-multi-svc] Multi-SVC", func() {
 			}
 
 			ginkgo.By("Create StatefulSet with 3 replica with parallel pod management")
-			service, statefulset, err := k8testutil.CreateStafeulSetAndVerifyPVAndPodNodeAffinty(ctx, client,
+			service, statefulset, err := k8testutil.CreateStatefulSetAndVerifyPVAndPodNodeAffinty(ctx, client,
 				e2eTestConfig, namespace, true, 3, false, nil, false, false, true, "", nil, false,
 				storagePolicyNames[n])
 			gomega.Expect(err).NotTo(gomega.HaveOccurred())