implement priority queue

Signed-off-by: Troy Connor <[email protected]>

Author: troy0820

pkg/handler/enqueue.go

@@ -23,7 +23,6 @@ import (
 	"k8s.io/apimachinery/pkg/types"
 	"k8s.io/client-go/util/workqueue"
 	"sigs.k8s.io/controller-runtime/pkg/client"
-	"sigs.k8s.io/controller-runtime/pkg/controller/priorityqueue"
 	"sigs.k8s.io/controller-runtime/pkg/event"
 	logf "sigs.k8s.io/controller-runtime/pkg/internal/log"
 	"sigs.k8s.io/controller-runtime/pkg/reconcile"
@@ -59,12 +58,7 @@ func (e *TypedEnqueueRequestForObject[T]) Create(ctx context.Context, evt event.
 		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.
@@ -76,12 +70,7 @@ func (e *TypedEnqueueRequestForObject[T]) Update(ctx context.Context, evt event.
 			Namespace: evt.ObjectNew.GetNamespace(),
 		}}
 
-		priorityQueue, isPriorityQueue := q.(priorityqueue.PriorityQueue[reconcile.Request])
-		if !isPriorityQueue {
-			q.Add(item)
-			return
-		}
-		addToQueueUpdate(priorityQueue, evt, item)
+		addToQueueUpdate(q, evt, item)
 	case !isNil(evt.ObjectOld):
 		item := reconcile.Request{NamespacedName: types.NamespacedName{
 			Name:      evt.ObjectOld.GetName(),

pkg/handler/eventhandler.go

@@ -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.
@@ -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)
 				},
 			})
 		},