fix Redis connection over Unix socket (#318)

centrifugal · Sep 8, 2023 · 1d2f4d2 · 1d2f4d2
1 parent 419142b
commit 1d2f4d2
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/redis_shard.go b/redis_shard.go
@@ -123,6 +123,11 @@ func NewRedisShard(_ *Node, conf RedisShardConfig) (*RedisShard, error) {
 	} else if len(conf.ClusterAddresses) > 0 {
 		options.InitAddress = conf.ClusterAddresses
 	} else {
+		if conf.network == "unix" {
+			options.DialFn = func(s string, d *net.Dialer, c *tls.Config) (net.Conn, error) {
+				return d.Dial("unix", s)
+			}
+		}
 		options.InitAddress = []string{conf.address}
 	}