Skip to content

Commit 466ba19

Browse files
committed
EventsSynchro: delete cached event key
Signed-off-by: Iceber Gu <[email protected]>
1 parent 27d6020 commit 466ba19

File tree

1 file changed

+8
-2
lines changed

1 file changed

+8
-2
lines changed

pkg/synchromanager/clustersynchro/default_resource_synchro.go

Lines changed: 8 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -701,8 +701,14 @@ func (synchro *eventSynchro) OnUpdate(_, obj interface{}, _ bool) {
701701
_ = synchro.queue.Update(obj, false)
702702
}
703703

704-
func (*eventSynchro) OnDelete(obj interface{}, _ bool) {
705-
// ignore deletion event
704+
func (synchro *eventSynchro) OnDelete(obj interface{}, _ bool) {
705+
key, err := cache.DeletionHandlingMetaNamespaceKeyFunc(obj)
706+
if err != nil {
707+
return
708+
}
709+
synchro.rvsLock.Lock()
710+
delete(synchro.rvs, key)
711+
synchro.rvsLock.Unlock()
706712
}
707713

708714
func (*eventSynchro) OnSync(obj interface{}) {

0 commit comments

Comments
 (0)