enable object revisiting after a while

Signed-off-by: Di Xu <stephenhsu90@gmail.com>
dixudx · Oct 27, 2023 · e0b238f · e0b238f
1 parent a67b660
commit e0b238f
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/yacht.go b/yacht.go
@@ -289,6 +289,11 @@ func (c *Controller) processNextWorkItem() bool {
 	requeueAfter, err := c.handlerFunc(item)
 	if err == nil {
 		c.queue.Forget(item)
+		if requeueAfter != nil {
+			// Sometimes we may want to re-visit this object after a while.
+			// Put the item back on the work queue with delay.
+			c.queue.AddAfter(item, *requeueAfter)
+		}
 		return true
 	}