Support Timeseries resp 2

timeseries_commands_test.go

@@ -14,13 +14,27 @@ var _ = Describe("RedisTimeseries commands", Label("timeseries"), func() {
 	ctx := context.TODO()
 	var client *redis.Client
 
-	BeforeEach(func() {
-		client = redis.NewClient(&redis.Options{Addr: rediStackAddr})
-		Expect(client.FlushDB(ctx).Err()).NotTo(HaveOccurred())
+	setupRedisClient := func(protocolVersion int) *redis.Client {
+		return redis.NewClient(&redis.Options{
+			Addr:          "localhost:6379",
+			DB:            0,
+			Protocol:      protocolVersion,
+			UnstableResp3: true,
 		})
+	}
 
 	AfterEach(func() {
-		Expect(client.Close()).NotTo(HaveOccurred())
+		if client != nil {
+			client.FlushDB(ctx)
+			client.Close()
+		}
+	})
+
+	protocols := []int{2, 3}
+	for _, protocol := range protocols {
+		BeforeEach(func() {
+			client = setupRedisClient(protocol)
+			Expect(client.FlushAll(ctx).Err()).NotTo(HaveOccurred())
 		})
 
 		It("should TSCreate and TSCreateWithArgs", Label("timeseries", "tscreate", "tscreateWithArgs", "NonRedisEnterprise"), func() {
@@ -1076,4 +1090,5 @@ var _ = Describe("RedisTimeseries commands", Label("timeseries"), func() {
 			Expect(result["b"][2]).To(BeEquivalentTo([]interface{}{[]interface{}{int64(10), 8.0}, []interface{}{int64(0), 4.0}}))
 			Expect(result["d"][2]).To(BeEquivalentTo([]interface{}{[]interface{}{int64(10), 8.0}, []interface{}{int64(0), 4.0}}))
 		})
+	}
 })