Skip to content

Commit 15b71c5

Browse files
committed
feat: add some delays when detecting new resource changes
Signed-off-by: Zhiying Lin <[email protected]>
1 parent 3b17212 commit 15b71c5

File tree

1 file changed

+10
-2
lines changed

1 file changed

+10
-2
lines changed

pkg/controllers/resourcechange/resourcechange_controller.go

Lines changed: 10 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -187,7 +187,11 @@ func (r *Reconciler) findPlacementsSelectedDeletedResV1Beta1(res keys.ClusterWid
187187

188188
for _, crp := range matchedCrps {
189189
klog.V(2).InfoS("change in deleted object triggered v1beta1 placement reconcile", "obj", res, "crp", crp)
190-
r.PlacementControllerV1Beta1.Enqueue(crp)
190+
// schedule enqueue after 1 minute
191+
crpName := crp
192+
time.AfterFunc(time.Minute, func() {
193+
r.PlacementControllerV1Beta1.Enqueue(crpName)
194+
})
191195
}
192196
}
193197

@@ -255,7 +259,11 @@ func (r *Reconciler) triggerAffectedPlacementsForUpdatedClusterRes(key keys.Clus
255259
// Enqueue the CRPs for reconciliation.
256260
for crp := range matchedCRPs {
257261
klog.V(2).InfoS("Change in object triggered v1beta1 placement reconcile", "obj", key, "crp", crp)
258-
r.PlacementControllerV1Beta1.Enqueue(crp)
262+
// schedule enqueue after 1 minute
263+
crpName := crp
264+
time.AfterFunc(time.Minute, func() {
265+
r.PlacementControllerV1Beta1.Enqueue(crpName)
266+
})
259267
}
260268
}
261269

0 commit comments

Comments
 (0)