From 5a120d680733883e2080b9f01b039255ed98f69e Mon Sep 17 00:00:00 2001 From: Juan Calderon-Perez Date: Sat, 8 Apr 2023 18:42:55 -0700 Subject: [PATCH] Simplify logic of New function --- redis/redis.go | 10 ++++------ 1 file changed, 4 insertions(+), 6 deletions(-) diff --git a/redis/redis.go b/redis/redis.go index a32866ef..46da8e29 100644 --- a/redis/redis.go +++ b/redis/redis.go @@ -30,7 +30,7 @@ func New(config ...Config) *Storage { options.PoolSize = cfg.PoolSize db := redis.NewClient(options) } else if cfg.EnableFailover { - options := &redis.FailoverOptions{ + db := redis.NewFailoverClient(&redis.FailoverOptions{ MasterName: cfg.MasterName, SentinelAddrs: cfg.SentinelHosts, ClientName: cfg.ClientName, @@ -40,18 +40,16 @@ func New(config ...Config) *Storage { Password: cfg.Password, TLSConfig: cfg.TLSConfig, PoolSize: cfg.PoolSize, - } - db := redis.NewFailoverClient(options) + }) } else { - options := &redis.Options{ + db := redis.NewClient(&redis.Options{ Addr: fmt.Sprintf("%s:%d", cfg.Host, cfg.Port), DB: cfg.Database, Username: cfg.Username, Password: cfg.Password, TLSConfig: cfg.TLSConfig, PoolSize: cfg.PoolSize, - } - db := redis.NewClient(options) + }) } // Test connection