Fix: Used gofumpt and goimports for formatting the edited files

Signed-off-by: sadath-12 <sadathsadu2002@gmail.com>

Author: sadath-12

conformance/experimental_conformance_test.go

@@ -125,7 +125,7 @@ func testExperimentalConformance(t *testing.T) {
 	}
 
 	cSuite.Setup(t)
-	cSuite.Run(t, tests.ConformanceTests)
+	cSuite.Run(t, tests.ConformanceTests) 
 	report, err := cSuite.Report()
 	if err != nil {
 		t.Fatalf("error generating conformance profile report: %v", err)

conformance/utils/kubernetes/apply.go

@@ -137,45 +137,43 @@ func (a Applier) prepareResources(t *testing.T, decoder *yaml.YAMLOrJSONDecoder)
 }
 
 func (a Applier) MustApplyObjectsWithCleanup(t *testing.T, c client.Client, timeoutConfig config.TimeoutConfig, resources []client.Object, cleanup bool) {
-    fmt.Print("heyyy")
-    for _, resource := range resources {
-        resource := resource
-
-        ctx, cancel := context.WithTimeout(context.Background(), timeoutConfig.CreateTimeout)
-        defer cancel()
-
-        t.Logf("Creating/Updating %s %s", resource.GetName(), resource.GetObjectKind().GroupVersionKind().Kind)
-
-        // Check if the resource exists
-       existingResource := resource.DeepCopyObject().(client.Object)
-        err := c.Get(ctx, types.NamespacedName{Name: resource.GetName(), Namespace: resource.GetNamespace()}, existingResource)
-        if err != nil {
-            if !apierrors.IsNotFound(err) {
-                t.Logf("error checking resource: %s %s", resource.GetName(), resource.GetObjectKind().GroupVersionKind().Kind)
-                require.NoError(t, err, "error checking resource")
-            }
-
-            // Resource doesn't exist, create it
-            err = c.Create(ctx, resource)
-            require.NoError(t, err, "error creating resource")
-        } else {
-            // Resource exists, update it
-            err = c.Update(ctx, resource)
-            require.NoError(t, err, "error updating resource")
-        }
-		
-        if cleanup {
-            t.Cleanup(func() {
-                ctx, cancel = context.WithTimeout(context.Background(), timeoutConfig.DeleteTimeout)
-                defer cancel()
-                t.Logf("Deleting %s %s", resource.GetName(), resource.GetObjectKind().GroupVersionKind().Kind)
-                err = c.Delete(ctx, resource)
-                require.NoErrorf(t, err, "error deleting resource")
-            })
-        }
-    }
-}
+	for _, resource := range resources {
+		resource := resource
+
+		ctx, cancel := context.WithTimeout(context.Background(), timeoutConfig.CreateTimeout)
+		defer cancel()
+
+		t.Logf("Creating/Updating %s %s", resource.GetName(), resource.GetObjectKind().GroupVersionKind().Kind)
+
+		// Check if the resource exists
+		existingResource := resource.DeepCopyObject().(client.Object)
+		err := c.Get(ctx, types.NamespacedName{Name: resource.GetName(), Namespace: resource.GetNamespace()}, existingResource)
+		if err != nil {
+			if !apierrors.IsNotFound(err) {
+				t.Logf("error checking resource: %s %s", resource.GetName(), resource.GetObjectKind().GroupVersionKind().Kind)
+				require.NoError(t, err, "error checking resource")
+			}
+
+			// Resource doesn't exist, create it
+			err = c.Create(ctx, resource)
+			require.NoError(t, err, "error creating resource")
+		} else {
+			// Resource exists, update it
+			err = c.Update(ctx, resource)
+			require.NoError(t, err, "error updating resource")
+		}
 
+		if cleanup {
+			t.Cleanup(func() {
+				ctx, cancel = context.WithTimeout(context.Background(), timeoutConfig.DeleteTimeout)
+				defer cancel()
+				t.Logf("Deleting %s %s", resource.GetName(), resource.GetObjectKind().GroupVersionKind().Kind)
+				err = c.Delete(ctx, resource)
+				require.NoErrorf(t, err, "error deleting resource")
+			})
+		}
+	}
+}
 
 // MustApplyWithCleanup creates or updates Kubernetes resources defined with the
 // provided YAML file and registers a cleanup function for resources it created.
@@ -185,7 +183,7 @@ func (a Applier) MustApplyWithCleanup(t *testing.T, c client.Client, timeoutConf
 	require.NoError(t, err)
 
 	decoder := yaml.NewYAMLOrJSONDecoder(data, 4096)
- 
+
 	resources, err := a.prepareResources(t, decoder)
 	if err != nil {
 		t.Logf("manifest: %s", data.String())

conformance/utils/kubernetes/certificate.go

@@ -54,7 +54,7 @@ func MustCreateSelfSignedCertSecret(t *testing.T, namespace, secretName string,
 	data := map[string][]byte{
 		corev1.TLSCertKey:       serverCert.Bytes(),
 		corev1.TLSPrivateKeyKey: serverKey.Bytes(),
-	} 
+	}
 
 	newSecret := &corev1.Secret{
 		ObjectMeta: metav1.ObjectMeta{