Skip to content

Commit

Permalink
implement priority queue
Browse files Browse the repository at this point in the history
Signed-off-by: Troy Connor <[email protected]>
  • Loading branch information
troy0820 committed Feb 20, 2025
1 parent a3bd1c0 commit 10068c8
Showing 1 changed file with 2 additions and 13 deletions.
15 changes: 2 additions & 13 deletions pkg/handler/eventhandler.go
Original file line number Diff line number Diff line change
Expand Up @@ -101,13 +101,7 @@ func (f *funcs[T, R]) Create(ctx context.Context, evt event.TypedCreateEvent[T],
Name: evt.Object.GetName(),
Namespace: evt.Object.GetNamespace(),
}}

priorityQueue, isPriorityQueue := q.(priorityqueue.PriorityQueue[reconcile.Request])
if !isPriorityQueue {
q.Add(item)
return
}
addToQueueCreate(priorityQueue, evt, item)
addToQueueCreate(q, evt, item)
}

// Update implements EventHandler.
Expand Down Expand Up @@ -218,12 +212,7 @@ func WithLowPriorityWhenUnchanged[object client.Object, request comparable](u Ty
u.Create(ctx, tce, workqueueWithCustomAddFunc[request]{
TypedRateLimitingInterface: trli,
addFunc: func(item request, q workqueue.TypedRateLimitingInterface[request]) {
priorityQueue, isPriorityQueue := q.(priorityqueue.PriorityQueue[request])
if !isPriorityQueue {
q.Add(item)
return
}
addToQueueCreate(priorityQueue, tce, item)
addToQueueCreate(q, tce, item)
},
})
},
Expand Down

0 comments on commit 10068c8

Please sign in to comment.