diff --git a/pkg/client/redis/client.go b/pkg/client/redis/client.go index 7acd6a8..7de8c36 100644 --- a/pkg/client/redis/client.go +++ b/pkg/client/redis/client.go @@ -46,6 +46,10 @@ const ( redisPort = "6379" sentinelPort = "26379" masterName = "mymaster" + + defaultDownAfterMilliseconds = "5000" + defaultFailovertimeout = "6000" + defaultParallelSyncs = "2" ) var ( @@ -172,6 +176,22 @@ func (c *client) MonitorRedis(ip string, monitor string, quorum string, auth *ut } } + sCmd := rediscli.NewStatusCmd("SENTINEL", "SET", masterName, "down-after-milliseconds", defaultDownAfterMilliseconds) + rClient.Process(sCmd) + if err = sCmd.Err(); err != nil { + return err + } + sCmd = rediscli.NewStatusCmd("SENTINEL", "SET", masterName, "failover-timeout", defaultFailovertimeout) + rClient.Process(sCmd) + if err = sCmd.Err(); err != nil { + return err + } + sCmd = rediscli.NewStatusCmd("SENTINEL", "SET", masterName, "parallel-syncs", defaultParallelSyncs) + rClient.Process(sCmd) + if err = sCmd.Err(); err != nil { + return err + } + return nil }