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())
-	})
-})