chore(df): bump default version to v1.32.0 (#344)

* chore(df): bump default version to v1.32.0

Signed-off-by: Abhradeep Chakraborty <[email protected]>

* fix

Signed-off-by: Abhradeep Chakraborty <[email protected]>

---------

Signed-off-by: Abhradeep Chakraborty <[email protected]>

Author: Abhra303

e2e/dragonfly_controller_test.go

@@ -193,6 +193,7 @@ var _ = Describe("Dragonfly Lifecycle tests", Ordered, FlakeAttempts(3), func()
 			rc, err := checkAndK8sPortForwardRedis(ctx, clientset, cfg, stopChan, name, namespace, password, 6391)
 			Expect(err).To(BeNil())
 			defer close(stopChan)
+			defer rc.Close()
 
 			// insert test data
 			Expect(rc.Set(ctx, "foo", "bar", 0).Err()).To(BeNil())
@@ -306,7 +307,7 @@ var _ = Describe("Dragonfly Lifecycle tests", Ordered, FlakeAttempts(3), func()
 			}, &df)
 			Expect(err).To(BeNil())
 
-			df.Spec.Image = fmt.Sprintf("%s:%s", resources.DragonflyImage, "v1.28.1")
+			df.Spec.Image = fmt.Sprintf("%s:%s", resources.DragonflyImage, "v1.30.3")
 			err = k8sClient.Update(ctx, &df)
 			Expect(err).To(BeNil())
 		})
@@ -496,6 +497,7 @@ var _ = Describe("Dragonfly Lifecycle tests", Ordered, FlakeAttempts(3), func()
 			defer close(stopChan)
 			rc, err := checkAndK8sPortForwardRedis(ctx, clientset, cfg, stopChan, name, namespace, password, 6395)
 			Expect(err).To(BeNil())
+			defer rc.Close()
 
 			// Check for test data
 			data, err := rc.Get(ctx, "foo").Result()
@@ -721,6 +723,8 @@ var _ = Describe("Dragonfly tiering test with single replica", Ordered, FlakeAtt
 			stopChan := make(chan struct{}, 1)
 			rc, err := checkAndK8sPortForwardRedis(ctx, clientset, cfg, stopChan, name, namespace, "", 6393)
 			Expect(err).To(BeNil())
+			defer close(stopChan)
+			defer rc.Close()
 
 			// Insert BIG value (>64B so it is eligible for tiering)
 			const size = 1 << 20 // 1 MiB
@@ -735,7 +739,6 @@ var _ = Describe("Dragonfly tiering test with single replica", Ordered, FlakeAtt
 			Expect(entries).To(Equal(int64(0))) // make sure this matches your expectation
 
 			Expect(rc.Set(ctx, "foo", payload, 0).Err()).To(BeNil())
-			defer close(stopChan)
 
 			// Inserted one big key, tiered entries should be 1
 			infoStr, err = rc.Info(ctx, "tiered").Result()
@@ -842,6 +845,7 @@ var _ = Describe("Dragonfly PVC Test with single replica", Ordered, FlakeAttempt
 			// Insert test data
 			Expect(rc.Set(ctx, "foo", "bar", 0).Err()).To(BeNil())
 			close(stopChan)
+			rc.Close()
 
 			// delete the single replica
 			var pod corev1.Pod
@@ -870,6 +874,7 @@ var _ = Describe("Dragonfly PVC Test with single replica", Ordered, FlakeAttempt
 			stopChan = make(chan struct{}, 1)
 			rc, err = checkAndK8sPortForwardRedis(ctx, clientset, cfg, stopChan, name, namespace, "", 6394)
 			defer close(stopChan)
+			defer rc.Close()
 			Expect(err).To(BeNil())
 
 			// check if the Data exists

internal/resources/version.go

@@ -17,5 +17,5 @@ limitations under the License.
 package resources
 
 const (
-	Version = "v1.30.3"
+	Version = "v1.32.0"
 )