()
| 82 | } |
| 83 | |
| 84 | func mockRedisClientCluster() (*RedisClient, error) { |
| 85 | redisServer1, err := miniredis.Run() |
| 86 | if err != nil { |
| 87 | return nil, err |
| 88 | } |
| 89 | |
| 90 | redisServer2, err := miniredis.Run() |
| 91 | if err != nil { |
| 92 | return nil, err |
| 93 | } |
| 94 | |
| 95 | cfg := &RedisConfig{ |
| 96 | Expiration: time.Minute, |
| 97 | Timeout: 100 * time.Millisecond, |
| 98 | Endpoint: strings.Join([]string{ |
| 99 | redisServer1.Addr(), |
| 100 | redisServer2.Addr(), |
| 101 | }, ","), |
| 102 | } |
| 103 | |
| 104 | return NewRedisClient(cfg), nil |
| 105 | } |
no test coverage detected