Merge pull request #6743 from XiShanYongYe-Chang/handle-DeletedFinalStateUnknown

Handle the DeletedFinalStateUnknown object in deletion events

Author: karmada-bot

pkg/clusterdiscovery/clusterapi/clusterapi.go

@@ -112,6 +112,13 @@ func (d *ClusterDetector) OnUpdate(_, newObj interface{}) {
 
 // OnDelete handles object delete event and push the object to queue.
 func (d *ClusterDetector) OnDelete(obj interface{}) {
+	if tombstone, ok := obj.(cache.DeletedFinalStateUnknown); ok {
+		obj = tombstone.Obj
+		if obj == nil {
+			klog.Warningf("Failed to get object(%s) from tombstone", tombstone.Key)
+			return
+		}
+	}
 	d.OnAdd(obj)
 }
 

pkg/dependenciesdistributor/dependencies_distributor.go

@@ -160,6 +160,13 @@ func (d *DependenciesDistributor) OnUpdate(oldObj, newObj interface{}) {
 
 // OnDelete handles object delete event and push the object to queue.
 func (d *DependenciesDistributor) OnDelete(obj interface{}) {
+	if tombstone, ok := obj.(cache.DeletedFinalStateUnknown); ok {
+		obj = tombstone.Obj
+		if obj == nil {
+			klog.Warningf("Failed to get object(%s) from tombstone", tombstone.Key)
+			return
+		}
+	}
 	d.OnAdd(obj)
 }
 

pkg/detector/detector.go

@@ -368,6 +368,13 @@ func (d *ResourceDetector) OnUpdate(oldObj, newObj interface{}) {
 
 // OnDelete handles object delete event and push the object to queue.
 func (d *ResourceDetector) OnDelete(obj interface{}) {
+	if tombstone, ok := obj.(cache.DeletedFinalStateUnknown); ok {
+		obj = tombstone.Obj
+		if obj == nil {
+			klog.Warningf("Failed to get object(%s) from tombstone", tombstone.Key)
+			return
+		}
+	}
 	d.OnAdd(obj)
 }
 

pkg/search/backendstore/defaultstore.go

@@ -51,6 +51,13 @@ func NewDefaultBackend(cluster string) *Default {
 					cluster, us.GroupVersionKind().String(), us.GetNamespace(), us.GetName())
 			},
 			DeleteFunc: func(obj interface{}) {
+				if tombstone, ok := obj.(cache.DeletedFinalStateUnknown); ok {
+					obj = tombstone.Obj
+					if obj == nil {
+						klog.Warningf("Failed to get object(%s) from tombstone", tombstone.Key)
+						return
+					}
+				}
 				us, ok := obj.(*unstructured.Unstructured)
 				if !ok {
 					klog.Errorf("unexpected type %T", obj)

pkg/search/backendstore/opensearch.go

@@ -147,6 +147,13 @@ func (os *OpenSearch) ResourceEventHandlerFuncs() cache.ResourceEventHandler {
 			os.upsert(curObj)
 		},
 		DeleteFunc: func(obj interface{}) {
+			if tombstone, ok := obj.(cache.DeletedFinalStateUnknown); ok {
+				obj = tombstone.Obj
+				if obj == nil {
+					klog.Warningf("Failed to get object(%s) from tombstone", tombstone.Key)
+					return
+				}
+			}
 			os.delete(obj)
 		},
 	}