diff options
Diffstat (limited to 'vendor/github.com/go-redis/redis/sentinel_test.go')
-rw-r--r-- | vendor/github.com/go-redis/redis/sentinel_test.go | 88 |
1 files changed, 0 insertions, 88 deletions
diff --git a/vendor/github.com/go-redis/redis/sentinel_test.go b/vendor/github.com/go-redis/redis/sentinel_test.go deleted file mode 100644 index c67713cd0..000000000 --- a/vendor/github.com/go-redis/redis/sentinel_test.go +++ /dev/null @@ -1,88 +0,0 @@ -package redis_test - -import ( - "github.com/go-redis/redis" - - . "github.com/onsi/ginkgo" - . "github.com/onsi/gomega" -) - -var _ = Describe("Sentinel", func() { - var client *redis.Client - - BeforeEach(func() { - client = redis.NewFailoverClient(&redis.FailoverOptions{ - MasterName: sentinelName, - SentinelAddrs: []string{":" + sentinelPort}, - }) - Expect(client.FlushDB().Err()).NotTo(HaveOccurred()) - }) - - AfterEach(func() { - Expect(client.Close()).NotTo(HaveOccurred()) - }) - - It("should facilitate failover", func() { - // Set value on master. - err := client.Set("foo", "master", 0).Err() - Expect(err).NotTo(HaveOccurred()) - - // Verify. - val, err := sentinelMaster.Get("foo").Result() - Expect(err).NotTo(HaveOccurred()) - Expect(val).To(Equal("master")) - - // Create subscription. - ch := client.Subscribe("foo").Channel() - - // Wait until replicated. - Eventually(func() string { - return sentinelSlave1.Get("foo").Val() - }, "1s", "100ms").Should(Equal("master")) - Eventually(func() string { - return sentinelSlave2.Get("foo").Val() - }, "1s", "100ms").Should(Equal("master")) - - // Wait until slaves are picked up by sentinel. - Eventually(func() string { - return sentinel.Info().Val() - }, "10s", "100ms").Should(ContainSubstring("slaves=2")) - - // Kill master. - sentinelMaster.Shutdown() - Eventually(func() error { - return sentinelMaster.Ping().Err() - }, "5s", "100ms").Should(HaveOccurred()) - - // Wait for Redis sentinel to elect new master. - Eventually(func() string { - return sentinelSlave1.Info().Val() + sentinelSlave2.Info().Val() - }, "30s", "1s").Should(ContainSubstring("role:master")) - - // Check that client picked up new master. - Eventually(func() error { - return client.Get("foo").Err() - }, "5s", "100ms").ShouldNot(HaveOccurred()) - - // Publish message to check if subscription is renewed. - err = client.Publish("foo", "hello").Err() - Expect(err).NotTo(HaveOccurred()) - - var msg *redis.Message - Eventually(ch).Should(Receive(&msg)) - Expect(msg.Channel).To(Equal("foo")) - Expect(msg.Payload).To(Equal("hello")) - }) - - It("supports DB selection", func() { - Expect(client.Close()).NotTo(HaveOccurred()) - - client = redis.NewFailoverClient(&redis.FailoverOptions{ - MasterName: sentinelName, - SentinelAddrs: []string{":" + sentinelPort}, - DB: 1, - }) - err := client.Ping().Err() - Expect(err).NotTo(HaveOccurred()) - }) -}) |