public_git
/
postgres-operator
mirror of https://github.com/zalando/postgres-operator.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Check cluster UID 

Signed-off-by: Mikkel Oscar Lyderik Larsen <mikkel.larsen@zalando.de>
This commit is contained in:
Mikkel Oscar Lyderik Larsen 2025-12-18 19:47:51 +01:00
parent 2a31c403d0
commit fdbdbd433f
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
pkg/controller/postgresql.go
View File

@ -185,19 +185,25 @@ func (c *Controller) addCluster(lg *logrus.Entry, clusterName spec.NamespacedNam
func (c *Controller) processEvent(event ClusterEvent) { func (c *Controller) processEvent(event ClusterEvent) {
var clusterName spec.NamespacedName var clusterName spec.NamespacedName
var clHistory ringlog.RingLogger var clHistory ringlog.RingLogger
var clusterUID types.UID
var err error var err error
lg := c.logger.WithField("worker", event.WorkerID) lg := c.logger.WithField("worker", event.WorkerID)
if event.EventType == EventAdd || event.EventType == EventSync || event.EventType == EventRepair { if event.EventType == EventAdd || event.EventType == EventSync || event.EventType == EventRepair {
clusterName = util.NameFromMeta(event.NewSpec.ObjectMeta) clusterName = util.NameFromMeta(event.NewSpec.ObjectMeta)
clusterUID = event.NewSpec.UID
} else { } else {
clusterName = util.NameFromMeta(event.OldSpec.ObjectMeta) clusterName = util.NameFromMeta(event.OldSpec.ObjectMeta)
clusterUID = event.OldSpec.UID
} }
lg = lg.WithField("cluster-name", clusterName) lg = lg.WithField("cluster-name", clusterName)
c.clustersMu.RLock() c.clustersMu.RLock()
cl, clusterFound := c.clusters[clusterName] cl, clusterFound := c.clusters[clusterName]
if clusterFound && cl.UID != clusterUID {
clusterFound = false
}
if clusterFound { if clusterFound {
clHistory = c.clusterHistory[clusterName] clHistory = c.clusterHistory[clusterName]
} }