From 396db81fa4d1fc9b6cc9f4e1463a7b5bb81b97e5 Mon Sep 17 00:00:00 2001 From: Trial97 Date: Tue, 26 Feb 2019 13:41:47 +0200 Subject: [PATCH] Updated redis sentinel conection to try all conection before returning a error. closes#1410 --- engine/storage_redis.go | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/engine/storage_redis.go b/engine/storage_redis.go index 0d6db828a..b43f2322c 100644 --- a/engine/storage_redis.go +++ b/engine/storage_redis.go @@ -94,9 +94,15 @@ func NewRedisStorage(address string, db int, pass, mrshlerStr string, sentinelInsts[i] = &sentinelInst{addr: addr} if sentinelInsts[i].conn, err = sentinel.NewClientCustom("tcp", addr, maxConns, df, sentinelName); err != nil { - return nil, err + sentinelInsts[i].conn = nil + utils.Logger.Warning(fmt.Sprintf(" could not connenct to sentinel at address: %s because error: %s ", + sentinelInsts[i].addr, err.Error())) + // return nil, err } } + if err != nil { + return nil, err + } return &RedisStorage{maxConns: maxConns, ms: mrshler, cacheCfg: cacheCfg, sentinelName: sentinelName, sentinelInsts: sentinelInsts, db: db, pass: pass}, nil