From 87a962504fe14a99a71c9ad0bc8e8933e9a8ca15 Mon Sep 17 00:00:00 2001 From: Lakhan Samani Date: Sun, 16 Jul 2023 22:57:56 +0530 Subject: [PATCH] Increase timeout for redis --- server/memorystore/providers/redis/provider.go | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/server/memorystore/providers/redis/provider.go b/server/memorystore/providers/redis/provider.go index 894a75e..17fb475 100644 --- a/server/memorystore/providers/redis/provider.go +++ b/server/memorystore/providers/redis/provider.go @@ -9,6 +9,10 @@ import ( log "github.com/sirupsen/logrus" ) +const ( + dialTimeout = 60 * time.Second +) + // RedisClient is the interface for redis client & redis cluster client type RedisClient interface { HMSet(ctx context.Context, key string, values ...interface{}) *redis.BoolCmd @@ -41,8 +45,7 @@ func NewRedisProvider(redisURL string) (*provider, error) { urls := []string{opt.Addr} urlList := redisURLHostPortsList[1:] urls = append(urls, urlList...) - clusterOpt := &redis.ClusterOptions{Addrs: urls} - + clusterOpt := &redis.ClusterOptions{Addrs: urls, DialTimeout: dialTimeout} rdb := redis.NewClusterClient(clusterOpt) ctx := context.Background() _, err = rdb.Ping(ctx).Result() @@ -62,7 +65,7 @@ func NewRedisProvider(redisURL string) (*provider, error) { log.Debug("error parsing redis url: ", err) return nil, err } - + opt.DialTimeout = dialTimeout rdb := redis.NewClient(opt) ctx := context.Background() _, err = rdb.Ping(ctx).Result()