Compare commits

..

1 Commits

Author SHA1 Message Date
7fc5a26347 fixup set connected in hook
Some checks failed
codeql / analyze (go) (push) Failing after 46s
build / test (push) Has been cancelled
build / lint (push) Has been cancelled
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2024-11-28 09:49:29 +03:00

View File

@@ -22,9 +22,14 @@ func newEventHook(connected *atomic.Bool) *eventHook {
func (h *eventHook) DialHook(hook goredis.DialHook) goredis.DialHook { func (h *eventHook) DialHook(hook goredis.DialHook) goredis.DialHook {
return func(ctx context.Context, network, addr string) (net.Conn, error) { return func(ctx context.Context, network, addr string) (net.Conn, error) {
conn, err := hook(ctx, network, addr) conn, err := hook(ctx, network, addr)
if err != nil && !isRedisError(err) { if err != nil {
if !isRedisError(err) {
h.connected.Store(false) h.connected.Store(false)
} }
h.connected.Store(true)
} else {
h.connected.Store(true)
}
return conn, err return conn, err
} }
} }