1 package redis_test
2
3 import (
4 . "github.com/onsi/ginkgo"
5 . "github.com/onsi/gomega"
6
7 "github.com/go-redis/redis"
8 )
9
10 var _ = Describe("UniversalClient", func() {
11 var client redis.UniversalClient
12
13 AfterEach(func() {
14 if client != nil {
15 Expect(client.Close()).To(Succeed())
16 }
17 })
18
19 It("should connect to failover servers", func() {
20 client = redis.NewUniversalClient(&redis.UniversalOptions{
21 MasterName: sentinelName,
22 Addrs: []string{":" + sentinelPort},
23 })
24 Expect(client.Ping().Err()).NotTo(HaveOccurred())
25 })
26
27 It("should connect to simple servers", func() {
28 client = redis.NewUniversalClient(&redis.UniversalOptions{
29 Addrs: []string{redisAddr},
30 })
31 Expect(client.Ping().Err()).NotTo(HaveOccurred())
32 })
33
34 It("should connect to clusters", func() {
35 client = redis.NewUniversalClient(&redis.UniversalOptions{
36 Addrs: cluster.addrs(),
37 })
38 Expect(client.Ping().Err()).NotTo(HaveOccurred())
39 })
40
41 })
42
View as plain text