diff --git a/pkg/cache/redis/pool.go b/pkg/cache/redis/pool.go index 23a549d62..22d5ec5a6 100644 --- a/pkg/cache/redis/pool.go +++ b/pkg/cache/redis/pool.go @@ -61,18 +61,16 @@ func NewPool(c *Config, options ...DialOption) (p *Pool) { if c.DialTimeout <= 0 || c.ReadTimeout <= 0 || c.WriteTimeout <= 0 { panic("must config redis timeout") } - p1 := pool.NewSlice(c.Config) + var ops []DialOption cnop := DialConnectTimeout(time.Duration(c.DialTimeout)) - options = append(options, cnop) rdop := DialReadTimeout(time.Duration(c.ReadTimeout)) - options = append(options, rdop) wrop := DialWriteTimeout(time.Duration(c.WriteTimeout)) - options = append(options, wrop) auop := DialPassword(c.Auth) - options = append(options, auop) - // new pool + ops = append(ops, cnop, rdop, wrop, auop) + ops = append(ops, options...) + p1 := pool.NewSlice(c.Config) p1.New = func(ctx context.Context) (io.Closer, error) { - conn, err := Dial(c.Proto, c.Addr, options...) + conn, err := Dial(c.Proto, c.Addr, ops...) if err != nil { return nil, err }