Delay workqueue add by 10s and handle update events for Bearer/Blob

Author: wzshiming

pkg/controller/bearer_from_chunk_controller.go

@@ -59,7 +59,11 @@ func NewBearerFromChunkController(
 	c.bearerInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
 		AddFunc: func(obj interface{}) {
 			bearer := obj.(*v1alpha1.Bearer)
-			c.workqueue.Add(bearer.Name)
+			c.workqueue.AddAfter(bearer.Name, 10*time.Second)
+		},
+		UpdateFunc: func(oldObj, newObj interface{}) {
+			bearer := newObj.(*v1alpha1.Bearer)
+			c.workqueue.AddAfter(bearer.Name, 10*time.Second)
 		},
 	})
 

pkg/controller/blob_from_chunk_controller.go

@@ -72,7 +72,11 @@ func NewBlobFromChunkController(
 	c.blobInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
 		AddFunc: func(obj interface{}) {
 			blob := obj.(*v1alpha1.Blob)
-			c.workqueue.Add(blob.Name)
+			c.workqueue.AddAfter(blob.Name, 10*time.Second)
+		},
+		UpdateFunc: func(oldObj, newObj interface{}) {
+			blob := newObj.(*v1alpha1.Blob)
+			c.workqueue.AddAfter(blob.Name, 10*time.Second)
 		},
 	})