rdb.go

@@ -140,21 +140,18 @@ func newRedisPool(s RdSettings, logger logr.Logger) *redis.Pool {
 		idleTimeoutSec = 240
 	}
 
-	connStr := s.ConnStr()
-
-	if len(s.Prefix) > 0 {
-		logger = logger.WithValues("rd", s.Prefix)
-	}
-
 	return &redis.Pool{
 		Wait:        false,
 		MaxIdle:     maxIdle,
 		IdleTimeout: time.Second * time.Duration(idleTimeoutSec),
 		Dial: func() (redis.Conn, error) {
-			orig, err := redis.Dial("tcp", connStr)
+			orig, err := redis.Dial("tcp", s.ConnStr())
 			if err != nil {
 				return nil, errors.WithStack(err)
 			}
+			if len(s.Prefix) > 0 {
+				logger = logger.WithName("[" + s.Prefix + "]")
+			}
 			c := &rdb{
 				orig:   orig,
 				name:   s.Prefix,