From 1f75d30217edc6328de851defe2323ca73790c5c Mon Sep 17 00:00:00 2001 From: Ivan Trubach Date: Fri, 8 Sep 2023 09:43:00 +0300 Subject: [PATCH] fix Redis connection over Unix socket --- redis_shard.go | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/redis_shard.go b/redis_shard.go index eeceb253..ef320d4b 100644 --- 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} }