Skip to content

Commit 2e2227c

Browse files
committed
fix(queues): requeue events against all-namespace queue if present
1 parent 777d61c commit 2e2227c

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

pkg/lib/queueinformer/resourcequeue.go

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -39,6 +39,11 @@ func (r *ResourceQueueSet) RequeueEvent(namespace string, resourceEvent kubestat
3939
r.mutex.RLock()
4040
defer r.mutex.RUnlock()
4141

42+
// if queue, ok := r.queueSet[metav1.NamespaceAll]; len(r.queueSet) == 1 && ok {
43+
// queue.AddRateLimited(resourceEvent)
44+
// return nil
45+
// }
46+
4247
if queue, ok := r.queueSet[namespace]; ok {
4348
queue.AddRateLimited(resourceEvent)
4449
return nil

0 commit comments

Comments
 (0)