------------------------------------------------------------------------------
()
| 178 | //------------------------------------------------------------------------------ |
| 179 | |
| 180 | func redisOptions() *redis.Options { |
| 181 | if RECluster { |
| 182 | return &redis.Options{ |
| 183 | Addr: redisAddr, |
| 184 | DB: 0, |
| 185 | |
| 186 | DialTimeout: 10 * time.Second, |
| 187 | ReadTimeout: 30 * time.Second, |
| 188 | WriteTimeout: 30 * time.Second, |
| 189 | ContextTimeoutEnabled: true, |
| 190 | |
| 191 | MaxRetries: -1, |
| 192 | |
| 193 | PoolSize: 10, |
| 194 | PoolTimeout: 30 * time.Second, |
| 195 | ConnMaxIdleTime: time.Minute, |
| 196 | } |
| 197 | } |
| 198 | return &redis.Options{ |
| 199 | Addr: redisAddr, |
| 200 | DB: 0, |
| 201 | |
| 202 | DialTimeout: 10 * time.Second, |
| 203 | ReadTimeout: 30 * time.Second, |
| 204 | WriteTimeout: 30 * time.Second, |
| 205 | ContextTimeoutEnabled: true, |
| 206 | |
| 207 | MaxRetries: -1, |
| 208 | |
| 209 | PoolSize: 10, |
| 210 | PoolTimeout: 30 * time.Second, |
| 211 | ConnMaxIdleTime: time.Minute, |
| 212 | } |
| 213 | } |
| 214 | |
| 215 | func redisClusterOptions() *redis.ClusterOptions { |
| 216 | return &redis.ClusterOptions{ |
no outgoing calls
no test coverage detected