|
@@ -59,8 +59,6 @@ func (h *Hub) createPool(addr string, opts ...redis.DialOption) (*redis.Pool, er
|
|
|
func (h *Hub) conn() error {
|
|
|
dialOpts := []redis.DialOption{
|
|
|
redis.DialConnectTimeout(5 * time.Second),
|
|
|
- redis.DialReadTimeout(50 * time.Millisecond),
|
|
|
- redis.DialWriteTimeout(50 * time.Millisecond),
|
|
|
}
|
|
|
|
|
|
nodes := viper.GetStringSlice("redis.nodes")
|