| 227 | } |
| 228 | |
| 229 | func redisRingOptions() *redis.RingOptions { |
| 230 | return &redis.RingOptions{ |
| 231 | Addrs: map[string]string{ |
| 232 | "ringShardOne": ":" + ringShard1Port, |
| 233 | "ringShardTwo": ":" + ringShard2Port, |
| 234 | }, |
| 235 | |
| 236 | DialTimeout: 10 * time.Second, |
| 237 | ReadTimeout: 30 * time.Second, |
| 238 | WriteTimeout: 30 * time.Second, |
| 239 | |
| 240 | MaxRetries: -1, |
| 241 | |
| 242 | PoolSize: 10, |
| 243 | PoolTimeout: 30 * time.Second, |
| 244 | ConnMaxIdleTime: time.Minute, |
| 245 | } |
| 246 | } |
| 247 | |
| 248 | func performAsync(n int, cbs ...func(int)) *sync.WaitGroup { |
| 249 | var wg sync.WaitGroup |