Skip to content

Commit dc7b00b

Browse files
authored
Remove operatorgroup queueinformer (#2753)
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 dc7b00b

File tree

1 file changed

+1
-13
lines changed

1 file changed

+1
-13
lines changed

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)