Skip to content

Commit fcee150

Browse files
committed
Remove operatorgroup queueinformer
Removes the unneccesary operatorgroup queueinformer, since only an operatorgroup lister is needed. Also ensures that the syncResolvingNamespace function is no longer triggered by operatorgroup events. Signed-off-by: Daniel Sover <[email protected]>
1 parent dbd5b6f commit fcee150

File tree

1 file changed

+1
-13
lines changed

1 file changed

+1
-13
lines changed

Diff for: pkg/controller/operators/catalog/operator.go

+1-13
Original file line numberDiff line numberDiff line change
@@ -259,19 +259,7 @@ func NewOperator(ctx context.Context, kubeconfigPath string, clock utilclock.Clo
259259

260260
operatorGroupInformer := crInformerFactory.Operators().V1().OperatorGroups()
261261
op.lister.OperatorsV1().RegisterOperatorGroupLister(metav1.NamespaceAll, operatorGroupInformer.Lister())
262-
ogQueue := workqueue.NewNamedRateLimitingQueue(workqueue.DefaultControllerRateLimiter(), "ogs")
263-
op.ogQueueSet.Set(metav1.NamespaceAll, ogQueue)
264-
operatorGroupQueueInformer, err := queueinformer.NewQueueInformer(
265-
ctx,
266-
queueinformer.WithLogger(op.logger),
267-
queueinformer.WithQueue(ogQueue),
268-
queueinformer.WithInformer(operatorGroupInformer.Informer()),
269-
queueinformer.WithSyncer(queueinformer.LegacySyncHandler(op.syncResolvingNamespace).ToSyncer()),
270-
)
271-
if err != nil {
272-
return nil, err
273-
}
274-
if err := op.RegisterQueueInformer(operatorGroupQueueInformer); err != nil {
262+
if err := op.RegisterInformer(operatorGroupInformer.Informer()); err != nil {
275263
return nil, err
276264
}
277265

0 commit comments

Comments
 (0)