@@ -24,6 +24,16 @@ var _ = Describe("UniversalClient", func() {
24
24
Expect (client .Ping (ctx ).Err ()).NotTo (HaveOccurred ())
25
25
})
26
26
27
+ It ("should connect to failover cluster" , Label ("NonRedisEnterprise" ), func () {
28
+ client = redis .NewUniversalClient (& redis.UniversalOptions {
29
+ MasterName : sentinelName ,
30
+ RouteRandomly : true ,
31
+ Addrs : sentinelAddrs ,
32
+ })
33
+ _ , ok := client .(* redis.ClusterClient )
34
+ Expect (ok ).To (BeTrue (), "expected a ClusterClient" )
35
+ })
36
+
27
37
It ("should connect to simple servers" , func () {
28
38
client = redis .NewUniversalClient (& redis.UniversalOptions {
29
39
Addrs : []string {redisAddr },
@@ -79,6 +89,7 @@ var _ = Describe("UniversalClient", func() {
79
89
err = client .Set (ctx , "somekey" , "somevalue" , 0 ).Err ()
80
90
Expect (err ).To (HaveOccurred ())
81
91
})
92
+
82
93
It ("should connect to clusters if IsClusterMode is set even if only a single address is provided" , Label ("NonRedisEnterprise" ), func () {
83
94
client = redis .NewUniversalClient (& redis.UniversalOptions {
84
95
Addrs : []string {cluster .addrs ()[0 ]},
@@ -96,4 +107,3 @@ var _ = Describe("UniversalClient", func() {
96
107
Expect (client .ClusterSlots (ctx ).Val ()).To (HaveLen (3 ))
97
108
})
98
109
})
99
-
0 commit comments