Add olm operator plug-in framework

Signed-off-by: perdasilva <[email protected]>

Author: perdasilva

pkg/controller/operators/olm/operator.go

@@ -61,6 +61,10 @@ var (
 	ErrAPIServiceOwnerConflict = errors.New("unable to adopt APIService")
 )
 
+// this unexported operator plugin slice provides and entrypoint for
+// downstream to inject its own plugins to augment the controller behavior
+var operatorPlugIns []OperatorPlugin
+
 type Operator struct {
 	queueinformer.Operator
 
@@ -91,6 +95,7 @@ type Operator struct {
 	clientAttenuator             *scoped.ClientAttenuator
 	serviceAccountQuerier        *scoped.UserDefinedServiceAccountQuerier
 	clientFactory                clients.Factory
+	plugins                      []OperatorPlugin
 }
 
 func NewOperator(ctx context.Context, options ...OperatorOption) (*Operator, error) {
@@ -148,10 +153,12 @@ func newOperatorWithConfig(ctx context.Context, config *operatorConfig) (*Operat
 		serviceAccountQuerier:        scoped.NewUserDefinedServiceAccountQuerier(config.logger, config.externalClient),
 		clientFactory:                clients.NewFactory(config.restConfig),
 		protectedCopiedCSVNamespaces: config.protectedCopiedCSVNamespaces,
+		plugins:                      operatorPlugIns,
 	}
 
 	// Set up syncing for namespace-scoped resources
 	k8sSyncer := queueinformer.LegacySyncHandler(op.syncObject).ToSyncerWithDelete(op.handleDeletion)
+
 	for _, namespace := range config.watchedNamespaces {
 		// Wire CSVs
 		csvInformer := externalversions.NewSharedInformerFactoryWithOptions(
@@ -588,6 +595,13 @@ func newOperatorWithConfig(ctx context.Context, config *operatorConfig) (*Operat
 		OverridesBuilderFunc: overridesBuilderFunc.GetDeploymentInitializer,
 	}
 
+	// initialize plugins
+	for _, plugin := range op.plugins {
+		if err := plugin.Init(ctx, config, op); err != nil {
+			return nil, fmt.Errorf("error initializing plugin: %s", err)
+		}
+	}
+
 	return op, nil
 }
 

pkg/controller/operators/olm/operator_plugin.go

@@ -0,0 +1,9 @@
+package olm
+
+import "context"
+
+// OperatorPlugin provides a simple interface
+// that can be used to extend the olm operator's functionality
+type OperatorPlugin interface {
+	Init(ctx context.Context, config *operatorConfig, operator *Operator) error
+}