We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
2 parents e5cde8f + f4ae0ba commit 00eeb1cCopy full SHA for 00eeb1c
ring_test.go
@@ -533,6 +533,16 @@ var _ = Describe("Ring watch", func() {
533
})
534
535
It("respects max size on multi", func() {
536
+ //this test checks the number of "pool.conn"
537
+ //if the health check is performed at the same time
538
+ //conn will be used, resulting in an abnormal number of "pool.conn".
539
+ //
540
+ //redis.NewRing() does not have an option to prohibit health checks.
541
+ //set a relatively large time here to avoid health checks.
542
+ opt := redisRingOptions()
543
+ opt.HeartbeatFrequency = 72 * time.Hour
544
+ ring = redis.NewRing(opt)
545
+
546
perform(1000, func(id int) {
547
var ping *redis.StatusCmd
548
0 commit comments