fix(redis): supports pass the tls server name for redis tls connection (

#5182)
juicedata · Sep 25, 2024 · ad6cf90 · ad6cf90
1 parent bd3553f
commit ad6cf90
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/pkg/meta/redis.go b/pkg/meta/redis.go
@@ -117,6 +117,7 @@ func newRedisMeta(driver, addr string, conf *Config) (Meta, error) {
 	certFile := query.pop("tls-cert-file")
 	keyFile := query.pop("tls-key-file")
 	caCertFile := query.pop("tls-ca-cert-file")
+	tlsServerName := query.pop("tls-server-name")
 	u.RawQuery = values.Encode()
 
 	hosts := u.Host
@@ -125,7 +126,7 @@ func newRedisMeta(driver, addr string, conf *Config) (Meta, error) {
 		return nil, fmt.Errorf("redis parse %s: %s", uri, err)
 	}
 	if opt.TLSConfig != nil {
-		opt.TLSConfig.ServerName = "" // use the host of each connection as ServerName
+		opt.TLSConfig.ServerName = tlsServerName // use the host of each connection as ServerName
 		opt.TLSConfig.InsecureSkipVerify = skipVerify != ""
 		if certFile != "" {
 			cert, err := tls.LoadX509KeyPair(certFile, keyFile)