This commit is contained in:
Mikkel Oscar Lyderik Larsen 2026-01-27 12:37:00 +01:00 committed by GitHub
commit 7d30645abe
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 6 additions and 0 deletions

View File

@ -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]
}