From 7e6ede5392711ac4a62a8a07e8a7b92e751a76da Mon Sep 17 00:00:00 2001 From: Juan Calderon-Perez Date: Sat, 8 Apr 2023 18:49:01 -0700 Subject: [PATCH] Fix undefined var issues --- redis/redis.go | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/redis/redis.go b/redis/redis.go index 46da8e29..b60ab46d 100644 --- a/redis/redis.go +++ b/redis/redis.go @@ -19,6 +19,8 @@ func New(config ...Config) *Storage { cfg := configDefault(config...) // Create new redis client + var db *redis.Client + if cfg.URL != "" && !cfg.EnableFailover { options, err := redis.ParseURL(cfg.URL) @@ -28,9 +30,9 @@ func New(config ...Config) *Storage { options.TLSConfig = cfg.TLSConfig options.PoolSize = cfg.PoolSize - db := redis.NewClient(options) + db = redis.NewClient(options) } else if cfg.EnableFailover { - db := redis.NewFailoverClient(&redis.FailoverOptions{ + db = redis.NewFailoverClient(&redis.FailoverOptions{ MasterName: cfg.MasterName, SentinelAddrs: cfg.SentinelHosts, ClientName: cfg.ClientName, @@ -42,7 +44,7 @@ func New(config ...Config) *Storage { PoolSize: cfg.PoolSize, }) } else { - db := redis.NewClient(&redis.Options{ + db = redis.NewClient(&redis.Options{ Addr: fmt.Sprintf("%s:%d", cfg.Host, cfg.Port), DB: cfg.Database, Username: cfg.Username,