package redis_test import ( . "github.com/bsm/ginkgo/v2" . "github.com/bsm/gomega" "github.com/redis/go-redis/v9" ) var _ = Describe("UniversalClient", func() { var client redis.UniversalClient AfterEach(func() { if client != nil { Expect(client.Close()).To(Succeed()) } }) It("should connect to failover servers", func() { Skip("Flaky Test") client = redis.NewUniversalClient(&redis.UniversalOptions{ MasterName: sentinelName, Addrs: sentinelAddrs, }) Expect(client.Ping(ctx).Err()).NotTo(HaveOccurred()) }) It("should connect to simple servers", func() { client = redis.NewUniversalClient(&redis.UniversalOptions{ Addrs: []string{redisAddr}, }) Expect(client.Ping(ctx).Err()).NotTo(HaveOccurred()) }) It("should connect to clusters", Label("NonRedisEnterprise"), func() { client = redis.NewUniversalClient(&redis.UniversalOptions{ Addrs: cluster.addrs(), }) Expect(client.Ping(ctx).Err()).NotTo(HaveOccurred()) }) })