diff options
| author | Chia <Chia@93.nz> | 2026-08-05 09:26:05 +1200 |
|---|---|---|
| committer | Chia <Chia@93.nz> | 2026-08-05 09:26:05 +1200 |
| commit | 86b1f42e3c5601ff10621a9779cf0076590797a1 (patch) | |
| tree | ccf584f0404dece2e4dae2eee847b665f57c0737 /internal/controlplane/manager.go | |
| parent | 1a3d7f9a8a181df48f0e911cbe17a3fad3ab9ac9 (diff) | |
add sth.
Diffstat (limited to 'internal/controlplane/manager.go')
| -rw-r--r-- | internal/controlplane/manager.go | 4 |
1 files changed, 4 insertions, 0 deletions
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 |