From 86b1f42e3c5601ff10621a9779cf0076590797a1 Mon Sep 17 00:00:00 2001 From: Chia Date: Wed, 5 Aug 2026 09:26:05 +1200 Subject: add sth. --- internal/controlplane/manager.go | 4 ++++ 1 file changed, 4 insertions(+) (limited to 'internal/controlplane/manager.go') diff --git a/internal/controlplane/manager.go b/internal/controlplane/manager.go index cdafc36..b6be748 100644 --- a/internal/controlplane/manager.go +++ b/internal/controlplane/manager.go @@ -176,6 +176,10 @@ func (m *Manager) runSubscriptions(ctx context.Context) { closed = true continue } + // go-redis transparently reconnects Pub/Sub after a network outage. + // Receiving a message is the strongest signal that this subscription + // is live again, including when a concurrent publish previously failed. + m.redisConnected.Store(true) var event ChangeEvent if json.Unmarshal([]byte(message.Payload), &event) != nil || event.Generation <= m.generation.Load() { continue -- cgit v1.2.3