debug(): compare resource versions
This commit is contained in:
@@ -26,9 +26,26 @@ func StartLeaseInformer(cfg *Config, stopCh <-chan struct{}) error {
|
|||||||
|
|
||||||
leaseInformer.AddEventHandler(cache.ResourceEventHandlerFuncs{
|
leaseInformer.AddEventHandler(cache.ResourceEventHandlerFuncs{
|
||||||
AddFunc: func(obj interface{}) {
|
AddFunc: func(obj interface{}) {
|
||||||
|
if l, ok := obj.(*v1.Lease); ok {
|
||||||
|
log.WithFields(log.Fields{"Caller": "lease.Add", "Lease": l.Name, "RV": l.ResourceVersion}).Debug("Add event for lease")
|
||||||
|
}
|
||||||
handleLease(obj, cfg)
|
handleLease(obj, cfg)
|
||||||
},
|
},
|
||||||
UpdateFunc: func(oldObj, newObj interface{}) {
|
UpdateFunc: func(oldObj, newObj interface{}) {
|
||||||
|
oldL, okOld := oldObj.(*v1.Lease)
|
||||||
|
newL, okNew := newObj.(*v1.Lease)
|
||||||
|
if okOld {
|
||||||
|
log.WithFields(log.Fields{"Caller": "lease.Update.old", "Lease": oldL.Name, "RV": oldL.ResourceVersion}).Debug("Old lease")
|
||||||
|
}
|
||||||
|
if okNew {
|
||||||
|
log.WithFields(log.Fields{"Caller": "lease.Update.new", "Lease": newL.Name, "RV": newL.ResourceVersion}).Debug("New lease")
|
||||||
|
}
|
||||||
|
// Only handle when resourceVersion changed (actual update), skip resync/identical events
|
||||||
|
if okOld && okNew {
|
||||||
|
if oldL.ResourceVersion == newL.ResourceVersion {
|
||||||
|
return
|
||||||
|
}
|
||||||
|
}
|
||||||
handleLease(newObj, cfg)
|
handleLease(newObj, cfg)
|
||||||
},
|
},
|
||||||
DeleteFunc: func(obj interface{}) {
|
DeleteFunc: func(obj interface{}) {
|
||||||
|
|||||||
Reference in New Issue
Block a user