Merge pull request #30229 from mwielgus/delaying-del-2

federation/pkg/federation-controller/util/delaying_deliverer.go

@@ -140,6 +140,7 @@ func (d *DelayingDeliverer) Stop() {
 	close(d.stopChannel)
 }
 
+// Delivers value at the given time.
 func (d *DelayingDeliverer) DeliverAt(key string, value interface{}, deliveryTime time.Time) {
 	d.updateChannel <- &DelayingDelivererItem{
 		Key:          key,
@@ -147,3 +148,8 @@ func (d *DelayingDeliverer) DeliverAt(key string, value interface{}, deliveryTim
 		DeliveryTime: deliveryTime,
 	}
 }
+
+// Delivers value after the given delay.
+func (d *DelayingDeliverer) DeliverAfter(key string, value interface{}, delay time.Duration) {
+	d.DeliverAt(key, value, time.Now().Add(delay))
+}