feat(operators): add v2alpha1 operator controller

Add support for reconciling the v2alpha1 Operator API:
- generate Operator resources when none exist and labeled components
  found
- aggregate component references in the status of their respective
  Operators
- aggregate component status conditions to their respective Operators
- enabled by specifying the "OperatorLifecycleManagerV2" feature gate option
  when invoking the olm command

Also:
- regenerate clients and fakes

Author: njhale

cmd/olm/main.go

@@ -3,7 +3,6 @@ package main
 import (
 	"context"
 	"crypto/tls"
-	"flag"
 	"fmt"
 	"net/http"
 	"os"
@@ -14,12 +13,13 @@ import (
 	configv1client "github.com/openshift/client-go/config/clientset/versioned/typed/config/v1"
 	"github.com/operator-framework/operator-lifecycle-manager/pkg/lib/queueinformer"
 	"github.com/prometheus/client_golang/prometheus/promhttp"
-	log "github.com/sirupsen/logrus"
+	"github.com/sirupsen/logrus"
+	"github.com/spf13/pflag"
 	v1 "k8s.io/api/core/v1"
-	"k8s.io/client-go/tools/clientcmd"
 
-	"github.com/operator-framework/operator-lifecycle-manager/pkg/api/client"
+	"github.com/operator-framework/operator-lifecycle-manager/pkg/api/client/clientset/versioned"
 	"github.com/operator-framework/operator-lifecycle-manager/pkg/controller/operators/olm"
+	"github.com/operator-framework/operator-lifecycle-manager/pkg/feature"
 	"github.com/operator-framework/operator-lifecycle-manager/pkg/lib/filemonitor"
 	"github.com/operator-framework/operator-lifecycle-manager/pkg/lib/operatorclient"
 	"github.com/operator-framework/operator-lifecycle-manager/pkg/lib/operatorstatus"
@@ -37,53 +37,53 @@ const (
 
 // config flags defined globally so that they appear on the test binary as well
 var (
-	kubeConfigPath = flag.String(
-		"kubeconfig", "", "absolute path to the kubeconfig file")
-
-	wakeupInterval = flag.Duration(
+	wakeupInterval = pflag.Duration(
 		"interval", defaultWakeupInterval, "wake up interval")
 
-	watchedNamespaces = flag.String(
+	watchedNamespaces = pflag.String(
 		"watchedNamespaces", "", "comma separated list of namespaces for olm operator to watch. "+
 			"If not set, or set to the empty string (e.g. `-watchedNamespaces=\"\"`), "+
 			"olm operator will watch all namespaces in the cluster.")
 
-	writeStatusName = flag.String(
+	writeStatusName = pflag.String(
 		"writeStatusName", defaultOperatorName, "ClusterOperator name in which to write status, set to \"\" to disable.")
 
-	writePackageServerStatusName = flag.String(
+	writePackageServerStatusName = pflag.String(
 		"writePackageServerStatusName", defaultPackageServerStatusName, "ClusterOperator name in which to write status for package API server, set to \"\" to disable.")
 
-	debug = flag.Bool(
+	debug = pflag.Bool(
 		"debug", false, "use debug log level")
 
-	version = flag.Bool("version", false, "displays olm version")
+	version = pflag.Bool("version", false, "displays olm version")
 
-	tlsKeyPath = flag.String(
+	tlsKeyPath = pflag.String(
 		"tls-key", "", "Path to use for private key (requires tls-cert)")
 
-	tlsCertPath = flag.String(
+	tlsCertPath = pflag.String(
 		"tls-cert", "", "Path to use for certificate key (requires tls-key)")
 
-	profiling = flag.Bool(
+	profiling = pflag.Bool(
 		"profiling", false, "serve profiling data (on port 8080)")
 
-	namespace = flag.String(
+	namespace = pflag.String(
 		"namespace", "", "namespace where cleanup runs")
 )
 
 func init() {
 	metrics.RegisterOLM()
+
+	// Add feature gates before parsing
+	feature.AddFlag(pflag.CommandLine)
 }
 
 // main function - entrypoint to OLM operator
 func main() {
 	// Get exit signal context
 	ctx, cancel := context.WithCancel(signals.Context())
 	defer cancel()
+	pflag.Parse()
 
 	// Parse the command-line flags.
-	flag.Parse()
 
 	// Check if version flag was set
 	if *version {
@@ -104,9 +104,9 @@ func main() {
 	}
 
 	// Set log level to debug if `debug` flag set
-	logger := log.New()
+	logger := logrus.New()
 	if *debug {
-		logger.SetLevel(log.DebugLevel)
+		logger.SetLevel(logrus.DebugLevel)
 	}
 	logger.Infof("log level %s", logger.Level)
 
@@ -169,24 +169,27 @@ func main() {
 		}()
 	}
 
-	// create a config client for operator status
-	config, err := clientcmd.BuildConfigFromFlags("", *kubeConfigPath)
+	mgr, err := Manager(ctx)
 	if err != nil {
-		log.Fatalf("error configuring client: %s", err.Error())
+		logger.WithError(err).Fatalf("error configuring controller manager")
 	}
+	config := mgr.GetConfig()
+
 	versionedConfigClient, err := configclientset.NewForConfig(config)
 	if err != nil {
-		err = fmt.Errorf("error configuring OpenShift Proxy client: %v", err)
-		return
+		logger.WithError(err).Fatal("error configuring openshift proxy client")
 	}
 	configClient, err := configv1client.NewForConfig(config)
 	if err != nil {
-		log.Fatalf("error configuring client: %s", err.Error())
+		logger.WithError(err).Fatal("error configuring config client")
 	}
-	opClient := operatorclient.NewClientFromConfig(*kubeConfigPath, logger)
-	crClient, err := client.NewClient(*kubeConfigPath)
+	opClient, err := operatorclient.NewClientFromRestConfig(config)
 	if err != nil {
-		log.Fatalf("error configuring client: %s", err.Error())
+		logger.WithError(err).Fatal("error configuring operator client")
+	}
+	crClient, err := versioned.NewForConfig(config)
+	if err != nil {
+		logger.WithError(err).Fatal("error configuring custom resource client")
 	}
 
 	cleanup(logger, opClient, crClient)
@@ -203,7 +206,7 @@ func main() {
 		olm.WithConfigClient(versionedConfigClient),
 	)
 	if err != nil {
-		log.WithError(err).Fatalf("error configuring operator")
+		logger.WithError(err).Fatalf("error configuring operator")
 		return
 	}
 
@@ -227,5 +230,10 @@ func main() {
 		go monitor.Run(op.Done())
 	}
 
+	// Start the controller manager
+	if err := mgr.Start(ctx.Done()); err != nil {
+		logger.WithError(err).Fatal("controller manager stopped")
+	}
+
 	<-op.Done()
 }

cmd/olm/manager.go

@@ -0,0 +1,76 @@
+package main
+
+import (
+	"context"
+	"fmt"
+
+	"github.com/operator-framework/api/crds"
+	apiextensionsv1 "k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset/typed/apiextensions/v1"
+	apierrors "k8s.io/apimachinery/pkg/api/errors"
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	ctrl "sigs.k8s.io/controller-runtime"
+	"sigs.k8s.io/controller-runtime/pkg/log/zap"
+
+	"github.com/operator-framework/operator-lifecycle-manager/pkg/controller/operators"
+	"github.com/operator-framework/operator-lifecycle-manager/pkg/feature"
+)
+
+var log = ctrl.Log.WithName("manager")
+
+func Manager(ctx context.Context) (ctrl.Manager, error) {
+	ctrl.SetLogger(zap.Logger(true))
+	setupLog := log.WithName("setup").V(1)
+
+	// Setup a Manager
+	setupLog.Info("configuring manager")
+	mgr, err := ctrl.NewManager(ctrl.GetConfigOrDie(), ctrl.Options{MetricsBindAddress: "0"}) // TODO(njhale): Enable metrics on non-conflicting port (not 8080)
+	if err != nil {
+		return nil, err
+	}
+
+	// Setup a new controller to reconcile Operators
+	setupLog.Info("configuring controller")
+	client, err := apiextensionsv1.NewForConfig(mgr.GetConfig())
+	if err != nil {
+		return nil, err
+	}
+
+	if feature.Gate.Enabled(feature.OperatorLifecycleManagerV2) {
+		setupLog.Info(fmt.Sprintf("feature enabled: %v", feature.OperatorLifecycleManagerV2))
+
+		reconciler, err := operators.NewOperatorReconciler(
+			mgr.GetClient(),
+			ctrl.Log.WithName("controllers").WithName("operator"),
+			mgr.GetScheme(),
+		)
+		if err != nil {
+			return nil, err
+		}
+
+		crd, err := client.CustomResourceDefinitions().Create(crds.Operator())
+		if err != nil {
+			if !apierrors.IsAlreadyExists(err) {
+				return nil, err
+			}
+
+			// Already exists, try to update
+			if crd, err = client.CustomResourceDefinitions().Get(crds.Operator().GetName(), metav1.GetOptions{}); err != nil {
+				return nil, err
+			}
+
+			crd.Spec = crds.Operator().Spec
+			if _, err = client.CustomResourceDefinitions().Update(crd); err != nil {
+				return nil, err
+			}
+		}
+		setupLog.Info("v2alpha1 CRDs installed")
+
+		if err = reconciler.SetupWithManager(mgr); err != nil {
+			return nil, err
+		}
+	}
+
+	setupLog.Info("manager configured")
+
+	return mgr, nil
+}

deploy/chart/templates/0000_50_olm_07-olm-operator.deployment.yaml

@@ -26,32 +26,32 @@ spec:
           command:
           - /bin/olm
           args:
-          - -namespace
+          - --namespace
           - $(OPERATOR_NAMESPACE)
           {{- if .Values.watchedNamespaces }}
-          - -watchedNamespaces
+          - --watchedNamespaces
           - {{ .Values.watchedNamespaces }}
           {{- end }}
           {{- if .Values.olm.commandArgs }}
           - {{ .Values.olm.commandArgs }}
           {{- end }}
           {{- if .Values.debug }}
-          - -debug
+          - --debug
           {{- end }}
           {{- if .Values.writeStatusName }}
-          - -writeStatusName
+          - --writeStatusName
           - {{ .Values.writeStatusName }}
           {{- end }}
           {{- if .Values.writePackageServerStatusName }}
-          - -writePackageServerStatusName
+          - --writePackageServerStatusName
           - {{ .Values.writePackageServerStatusName }}
           {{- end }}
           {{- if .Values.olm.tlsCertPath }}
-          - -tls-cert
+          - --tls-cert
           - {{ .Values.olm.tlsCertPath }}
           {{- end }}
           {{- if .Values.olm.tlsKeyPath }}
-          - -tls-key
+          - --tls-key
           - {{ .Values.olm.tlsKeyPath }}
           {{- end }}
           image: {{ .Values.olm.image.ref }}

pkg/controller/bundle/bundle_unpacker.go

@@ -18,8 +18,8 @@ import (
 	listerscorev1 "k8s.io/client-go/listers/core/v1"
 	listersrbacv1 "k8s.io/client-go/listers/rbac/v1"
 
-	operatorsv1alpha1 "github.com/operator-framework/api/pkg/operators/v1alpha1"
 	"github.com/operator-framework/api/pkg/operators/reference"
+	operatorsv1alpha1 "github.com/operator-framework/api/pkg/operators/v1alpha1"
 	listersoperatorsv1alpha1 "github.com/operator-framework/operator-lifecycle-manager/pkg/api/client/listers/operators/v1alpha1"
 )