From fdbdbd433fdf78b73df4067eba7ea6ba33d8acc7 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 0725ffc1d..9d50b7318 100644 --- a/pkg/controller/postgresql.go +++ b/pkg/controller/postgresql.go @@ -185,19 +185,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] }