mirror of https://github.com/go-redis/redis.git
fix unstable ut: should facilitate failover
This commit is contained in:
parent
6e0ed33250
commit
c7eeca2a5c
|
@ -3,10 +3,10 @@ package redis_test
|
||||||
import (
|
import (
|
||||||
"net"
|
"net"
|
||||||
|
|
||||||
"github.com/go-redis/redis/v8"
|
|
||||||
|
|
||||||
. "github.com/onsi/ginkgo"
|
. "github.com/onsi/ginkgo"
|
||||||
. "github.com/onsi/gomega"
|
. "github.com/onsi/gomega"
|
||||||
|
|
||||||
|
"github.com/go-redis/redis/v8"
|
||||||
)
|
)
|
||||||
|
|
||||||
var _ = Describe("Sentinel", func() {
|
var _ = Describe("Sentinel", func() {
|
||||||
|
@ -188,7 +188,7 @@ var _ = Describe("NewFailoverClusterClient", func() {
|
||||||
ch := client.Subscribe(ctx, "foo").Channel()
|
ch := client.Subscribe(ctx, "foo").Channel()
|
||||||
|
|
||||||
// Kill master.
|
// Kill master.
|
||||||
err = master.Shutdown(ctx).Err()
|
err = master.ShutdownNoSave(ctx).Err()
|
||||||
Expect(err).NotTo(HaveOccurred())
|
Expect(err).NotTo(HaveOccurred())
|
||||||
Eventually(func() error {
|
Eventually(func() error {
|
||||||
return sentinelMaster.Ping(ctx).Err()
|
return sentinelMaster.Ping(ctx).Err()
|
||||||
|
|
Loading…
Reference in New Issue