Merge pull request #75 from jellor/delete-gateway

handle DeletedFinalStateUnknown in deleteGateway
openyurtio · Nov 14, 2022 · f9ad2fa · f9ad2fa
2 parents 12398c3 + f69371b
commit f9ad2fa
Showing 1 changed file with 13 additions and 1 deletion.
diff --git a/pkg/k8s/engine_controller.go b/pkg/k8s/engine_controller.go
@@ -303,7 +303,19 @@ func (c *EngineController) updateGateway(oldObj interface{}, newObj interface{})
 }
 
 func (c *EngineController) deleteGateway(obj interface{}) {
-	gw := obj.(*v1alpha1.Gateway)
+	gw, ok := obj.(*v1alpha1.Gateway)
+	if !ok {
+		tombstone, ok := obj.(cache.DeletedFinalStateUnknown)
+		if !ok {
+			klog.Errorf("couldn't get object from tombstone %#v", obj)
+			return
+		}
+		gw, ok = tombstone.Obj.(*v1alpha1.Gateway)
+		if !ok {
+			klog.Errorf("tombstone contained object that is not a Gateway %#v", obj)
+			return
+		}
+	}
 	klog.InfoS("deleting gateway", "gateway", klog.KObj(gw))
 	c.enqueue(gw)
 }