[WIP] nerf to single worker

pkg/controller/operators/catalog/operator.go

@@ -168,7 +168,7 @@ func NewOperator(ctx context.Context, kubeconfigPath string, clock utilclock.Clo
 		return nil, err
 	}
 
-	queueOperator, err := queueinformer.NewOperator(opClient.KubernetesInterface().Discovery(), queueinformer.WithOperatorLogger(logger))
+	queueOperator, err := queueinformer.NewOperator(opClient.KubernetesInterface().Discovery(), queueinformer.WithOperatorLogger(logger), queueinformer.WithNumWorkers(1))
 	if err != nil {
 		return nil, err
 	}

pkg/controller/operators/catalogtemplate/operator.go

@@ -69,7 +69,7 @@ func NewOperator(ctx context.Context, kubeconfigPath string, logger *logrus.Logg
 		return nil, err
 	}
 
-	queueOperator, err := queueinformer.NewOperator(opClient.KubernetesInterface().Discovery(), queueinformer.WithOperatorLogger(logger))
+	queueOperator, err := queueinformer.NewOperator(opClient.KubernetesInterface().Discovery(), queueinformer.WithOperatorLogger(logger), queueinformer.WithNumWorkers(1))
 	if err != nil {
 		return nil, err
 	}

pkg/controller/operators/olm/operator.go

@@ -165,7 +165,7 @@ func newOperatorWithConfig(ctx context.Context, config *operatorConfig) (*Operat
 		return nil, err
 	}
 
-	queueOperator, err := queueinformer.NewOperator(config.operatorClient.KubernetesInterface().Discovery(), queueinformer.WithOperatorLogger(config.logger))
+	queueOperator, err := queueinformer.NewOperator(config.operatorClient.KubernetesInterface().Discovery(), queueinformer.WithOperatorLogger(config.logger), queueinformer.WithNumWorkers(1))
 	if err != nil {
 		return nil, err
 	}

pkg/lib/queueinformer/config.go

@@ -233,6 +233,6 @@ func (c *operatorConfig) validate() (err error) {
 func defaultOperatorConfig() *operatorConfig {
 	return &operatorConfig{
 		logger:     logrus.New(),
-		numWorkers: 2,
+		numWorkers: 1,
 	}
 }

pkg/package-server/provider/registry_test.go

@@ -91,7 +91,7 @@ func NewFakeRegistryProvider(ctx context.Context, clientObjs []runtime.Object, k
 	k8sClientFake := k8sfake.NewSimpleClientset(k8sObjs...)
 	opClientFake := operatorclient.NewClient(k8sClientFake, nil, nil)
 
-	op, err := queueinformer.NewOperator(opClientFake.KubernetesInterface().Discovery())
+	op, err := queueinformer.NewOperator(opClientFake.KubernetesInterface().Discovery(), queueinformer.WithNumWorkers(1))
 	if err != nil {
 		return nil, err
 	}

pkg/package-server/server/server.go

@@ -232,7 +232,7 @@ func (o *PackageServerOptions) Run(ctx context.Context) error {
 		return err
 	}
 
-	queueOperator, err := queueinformer.NewOperator(crClient.Discovery())
+	queueOperator, err := queueinformer.NewOperator(crClient.Discovery(), queueinformer.WithNumWorkers(1))
 	if err != nil {
 		return err
 	}