@@ -62,13 +62,13 @@ var _ = Describe("Sentinel", func() {
62
62
// Wait until slaves are picked up by sentinel.
63
63
Eventually (func () string {
64
64
return sentinel1 .Info (ctx ).Val ()
65
- }, "15s " , "100ms" ).Should (ContainSubstring ("slaves=2" ))
65
+ }, "20s " , "100ms" ).Should (ContainSubstring ("slaves=2" ))
66
66
Eventually (func () string {
67
67
return sentinel2 .Info (ctx ).Val ()
68
- }, "15s " , "100ms" ).Should (ContainSubstring ("slaves=2" ))
68
+ }, "20s " , "100ms" ).Should (ContainSubstring ("slaves=2" ))
69
69
Eventually (func () string {
70
70
return sentinel3 .Info (ctx ).Val ()
71
- }, "15s " , "100ms" ).Should (ContainSubstring ("slaves=2" ))
71
+ }, "20s " , "100ms" ).Should (ContainSubstring ("slaves=2" ))
72
72
})
73
73
74
74
AfterEach (func () {
@@ -92,7 +92,7 @@ var _ = Describe("Sentinel", func() {
92
92
Eventually (func () []string {
93
93
slavesAddr = redis .GetSlavesAddrByName (ctx , sentinel , sentinelName )
94
94
return slavesAddr
95
- }, "15s " , "100ms" ).Should (HaveLen (2 ))
95
+ }, "20s " , "100ms" ).Should (HaveLen (2 ))
96
96
Eventually (func () bool {
97
97
sync := true
98
98
for _ , addr := range slavesAddr {
@@ -104,7 +104,7 @@ var _ = Describe("Sentinel", func() {
104
104
_ = slave .Close ()
105
105
}
106
106
return sync
107
- }, "15s " , "100ms" ).Should (BeTrue ())
107
+ }, "20s " , "100ms" ).Should (BeTrue ())
108
108
109
109
// Create subscription.
110
110
pub := client .Subscribe (ctx , "foo" )
@@ -115,19 +115,19 @@ var _ = Describe("Sentinel", func() {
115
115
Expect (err ).NotTo (HaveOccurred ())
116
116
Eventually (func () error {
117
117
return master .Ping (ctx ).Err ()
118
- }, "15s " , "100ms" ).Should (HaveOccurred ())
118
+ }, "20s " , "100ms" ).Should (HaveOccurred ())
119
119
120
120
// Check that client picked up new master.
121
121
Eventually (func () string {
122
122
return client .Get (ctx , "foo" ).Val ()
123
- }, "15s " , "100ms" ).Should (Equal ("master" ))
123
+ }, "20s " , "100ms" ).Should (Equal ("master" ))
124
124
125
125
// Check if subscription is renewed.
126
126
var msg * redis.Message
127
127
Eventually (func () <- chan * redis.Message {
128
128
_ = client .Publish (ctx , "foo" , "hello" ).Err ()
129
129
return ch
130
- }, "15s " , "100ms" ).Should (Receive (& msg ))
130
+ }, "20s " , "100ms" ).Should (Receive (& msg ))
131
131
Expect (msg .Channel ).To (Equal ("foo" ))
132
132
Expect (msg .Payload ).To (Equal ("hello" ))
133
133
Expect (pub .Close ()).NotTo (HaveOccurred ())
@@ -217,13 +217,13 @@ var _ = Describe("NewFailoverClusterClient", func() {
217
217
// Wait until slaves are picked up by sentinel.
218
218
Eventually (func () string {
219
219
return sentinel1 .Info (ctx ).Val ()
220
- }, "15s " , "100ms" ).Should (ContainSubstring ("slaves=2" ))
220
+ }, "20s " , "100ms" ).Should (ContainSubstring ("slaves=2" ))
221
221
Eventually (func () string {
222
222
return sentinel2 .Info (ctx ).Val ()
223
- }, "15s " , "100ms" ).Should (ContainSubstring ("slaves=2" ))
223
+ }, "20s " , "100ms" ).Should (ContainSubstring ("slaves=2" ))
224
224
Eventually (func () string {
225
225
return sentinel3 .Info (ctx ).Val ()
226
- }, "15s " , "100ms" ).Should (ContainSubstring ("slaves=2" ))
226
+ }, "20s " , "100ms" ).Should (ContainSubstring ("slaves=2" ))
227
227
})
228
228
229
229
AfterEach (func () {
@@ -240,7 +240,7 @@ var _ = Describe("NewFailoverClusterClient", func() {
240
240
// Verify.
241
241
Eventually (func () string {
242
242
return client .Get (ctx , "foo" ).Val ()
243
- }, "15s " , "1ms" ).Should (Equal ("master" ))
243
+ }, "20s " , "1ms" ).Should (Equal ("master" ))
244
244
}
245
245
246
246
// Create subscription.
@@ -252,19 +252,19 @@ var _ = Describe("NewFailoverClusterClient", func() {
252
252
Expect (err ).NotTo (HaveOccurred ())
253
253
Eventually (func () error {
254
254
return master .Ping (ctx ).Err ()
255
- }, "15s " , "100ms" ).Should (HaveOccurred ())
255
+ }, "20s " , "100ms" ).Should (HaveOccurred ())
256
256
257
257
// Check that client picked up new master.
258
258
Eventually (func () string {
259
259
return client .Get (ctx , "foo" ).Val ()
260
- }, "15s " , "100ms" ).Should (Equal ("master" ))
260
+ }, "20s " , "100ms" ).Should (Equal ("master" ))
261
261
262
262
// Check if subscription is renewed.
263
263
var msg * redis.Message
264
264
Eventually (func () <- chan * redis.Message {
265
265
_ = client .Publish (ctx , "foo" , "hello" ).Err ()
266
266
return ch
267
- }, "15s " , "100ms" ).Should (Receive (& msg ))
267
+ }, "20s " , "100ms" ).Should (Receive (& msg ))
268
268
Expect (msg .Channel ).To (Equal ("foo" ))
269
269
Expect (msg .Payload ).To (Equal ("hello" ))
270
270
Expect (sub .Close ()).NotTo (HaveOccurred ())
@@ -342,7 +342,7 @@ var _ = Describe("SentinelAclAuth", func() {
342
342
for _ , process := range sentinels () {
343
343
Eventually (func () string {
344
344
return process .Info (ctx ).Val ()
345
- }, "15s " , "100ms" ).Should (ContainSubstring ("sentinels=3" ))
345
+ }, "20s " , "100ms" ).Should (ContainSubstring ("sentinels=3" ))
346
346
}
347
347
})
348
348
0 commit comments