[add] redis新增cluster与sentinel

- cluster已经过测试，sentinel暂未测试

Author: zicorn

internal/core/plugin_manager/manager.go

@@ -175,14 +175,44 @@ func (p *PluginManager) Launch(configuration *app.Config) {
 	log.Info("start plugin manager daemon...")
 
 	// init redis client
-	if err := cache.InitRedisClient(
-		fmt.Sprintf("%s:%d", configuration.RedisHost, configuration.RedisPort),
-		configuration.RedisUser,
-		configuration.RedisPass,
-		configuration.RedisUseSsl,
-		configuration.RedisDB,
-	); err != nil {
-		log.Panic("init redis client failed: %s", err.Error())
+	if configuration.RedisUseSentinel {
+		// use redis sentinel mode
+		if err := cache.InitRedisSentinelClient(
+			configuration.RedisSentinelServiceName,
+			configuration.RedisSentinels,
+			configuration.RedisUser,             // 对主从服务器使用原有的用户名
+			configuration.RedisPass,             // 对主从服务器使用原有的密码
+			configuration.RedisSentinelUsername, // 连接哨兵服务器的用户名
+			configuration.RedisSentinelPassword, // 连接哨兵服务器的密码
+			configuration.RedisUseSsl,
+			configuration.RedisDB,
+			configuration.RedisSentinelSocketTimeout,
+		); err != nil {
+			log.Panic("init redis sentinel client failed: %s", err.Error())
+		}
+		log.Info("redis sentinel client initialized")
+	} else if configuration.RedisUseClusters {
+		// use redis cluster mode
+		if err := cache.InitRedisClusterClient(
+			configuration.RedisClusters,
+			configuration.RedisClustersPassword,
+			configuration.RedisUseSsl,
+		); err != nil {
+			log.Panic("init redis cluster client failed: %s", err.Error())
+		}
+		log.Info("redis cluster client initialized")
+	} else {
+		// use redis standalone mode
+		if err := cache.InitRedisClient(
+			fmt.Sprintf("%s:%d", configuration.RedisHost, configuration.RedisPort),
+			configuration.RedisUser,
+			configuration.RedisPass,
+			configuration.RedisUseSsl,
+			configuration.RedisDB,
+		); err != nil {
+			log.Panic("init redis client failed: %s", err.Error())
+		}
+		log.Info("redis standalone client initialized")
 	}
 
 	invocation, err := real.NewDifyInvocationDaemon(

internal/types/app/config.go

@@ -72,13 +72,26 @@ type Config struct {
 	RoutinePoolSize int `envconfig:"ROUTINE_POOL_SIZE" validate:"required"`
 
 	// redis
-	RedisHost   string `envconfig:"REDIS_HOST" validate:"required"`
-	RedisPort   uint16 `envconfig:"REDIS_PORT" validate:"required"`
+	RedisHost   string `envconfig:"REDIS_HOST"`
+	RedisPort   uint16 `envconfig:"REDIS_PORT"`
 	RedisPass   string `envconfig:"REDIS_PASSWORD"`
 	RedisUser   string `envconfig:"REDIS_USERNAME"`
 	RedisUseSsl bool   `envconfig:"REDIS_USE_SSL"`
 	RedisDB     int    `envconfig:"REDIS_DB"`
 
+	// redis clusters
+	RedisUseClusters      bool     `envconfig:"REDIS_USE_CLUSTERS"`
+	RedisClusters         []string `envconfig:"REDIS_CLUSTERS"`
+	RedisClustersPassword string   `envconfig:"REDIS_CLUSTERS_PASSWORD"`
+
+	// redis sentinel
+	RedisUseSentinel           bool     `envconfig:"REDIS_USE_SENTINEL"`
+	RedisSentinels             []string `envconfig:"REDIS_SENTINELS"`
+	RedisSentinelServiceName   string   `envconfig:"REDIS_SENTINEL_SERVICE_NAME"`
+	RedisSentinelUsername      string   `envconfig:"REDIS_SENTINEL_USERNAME"`
+	RedisSentinelPassword      string   `envconfig:"REDIS_SENTINEL_PASSWORD"`
+	RedisSentinelSocketTimeout float64  `envconfig:"REDIS_SENTINEL_SOCKET_TIMEOUT" default:"0.1"`
+
 	// database
 	DBType            string `envconfig:"DB_TYPE" default:"postgresql"`
 	DBUsername        string `envconfig:"DB_USERNAME" validate:"required"`