From 140f6beae60baed833f76b0a730adad2c868046c Mon Sep 17 00:00:00 2001 From: Mikkel Oscar Lyderik Larsen Date: Thu, 18 Dec 2025 19:47:51 +0100 Subject: [PATCH] Check cluster UID Signed-off-by: Mikkel Oscar Lyderik Larsen --- pkg/controller/postgresql.go | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/pkg/controller/postgresql.go b/pkg/controller/postgresql.go index 824a030f4..338c9e9fa 100644 --- a/pkg/controller/postgresql.go +++ b/pkg/controller/postgresql.go @@ -184,19 +184,25 @@ func (c *Controller) addCluster(lg *logrus.Entry, clusterName spec.NamespacedNam func (c *Controller) processEvent(event ClusterEvent) { var clusterName spec.NamespacedName var clHistory ringlog.RingLogger + var clusterUID types.UID var err error lg := c.logger.WithField("worker", event.WorkerID) if event.EventType == EventAdd || event.EventType == EventSync || event.EventType == EventRepair { clusterName = util.NameFromMeta(event.NewSpec.ObjectMeta) + clusterUID = event.NewSpec.UID } else { clusterName = util.NameFromMeta(event.OldSpec.ObjectMeta) + clusterUID = event.OldSpec.UID } lg = lg.WithField("cluster-name", clusterName) c.clustersMu.RLock() cl, clusterFound := c.clusters[clusterName] + if clusterFound && cl.UID != clusterUID { + clusterFound = false + } if clusterFound { clHistory = c.clusterHistory[clusterName] }