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

Merge 8ec1917fe5 into d495825f4b

This commit is contained in:
Mikkel Oscar Lyderik Larsen 2026-03-02 11:14:56 +01:00 committed by GitHub
parent d495825f4b 8ec1917fe5
commit 90d0dff36d
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
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]
} }