redis master env

Kotodian · May 5, 2023 · ff4211e · ff4211e
1 parent 35f81f8
commit ff4211e
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/datasource/go-redis/redis.go b/datasource/go-redis/redis.go
@@ -17,6 +17,7 @@ const (
 	EnvMaxActiveConns = "REDIS_MAX_ACTIVE_CONNS"
 	EnvRedisPool      = "REDIS_POOL"
 	EnvReidsAuth      = "REDIS_AUTH"
+	EnvRedisMaster    = "REDIS_MASTER"
 )
 
 const (
@@ -36,8 +37,12 @@ func Init() {
 		return
 	}
 	if len(addrs) > 1 {
+		master := os.Getenv(EnvRedisMaster)
+		if len(master) == 0 {
+			master = "mymaster"
+		}
 		opts := &redis.FailoverOptions{
-			MasterName:     "mymaster",
+			MasterName:     master,
 			SentinelAddrs:  addrs,
 			RouteByLatency: true,
 		}