Add olm operator plug-in framework

Signed-off-by: perdasilva <[email protected]>
Upstream-repository: perdasilva
Upstream-commit: 0b015f83409cc1513668d1820051168cc3f2f0f9

Author: perdasilva

staging/operator-lifecycle-manager/pkg/controller/operators/olm/operator.go

@@ -60,6 +60,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
 
@@ -90,6 +94,7 @@ type Operator struct {
 	clientAttenuator             *scoped.ClientAttenuator
 	serviceAccountQuerier        *scoped.UserDefinedServiceAccountQuerier
 	clientFactory                clients.Factory
+	plugins                      []OperatorPlugin
 }
 
 func NewOperator(ctx context.Context, options ...OperatorOption) (*Operator, error) {
@@ -147,6 +152,7 @@ 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
@@ -587,6 +593,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
 }
 

staging/operator-lifecycle-manager/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
+}