use new workload controller with preconditions

pkg/operator/config/config.go

@@ -60,6 +60,12 @@ type OperatorControllerConfig struct {
 	GuestDaemonSetHooks []csidrivernodeservicecontroller.DaemonSetHookFunc
 	// List of informers that should be added to the guest DaemonSet controller.
 	GuestDaemonSetInformers []factory.Informer
+
+	// List of functions that should return true if we want the controller to sync normally.
+	// Returning false or error will degrade the cluster with OperatorCondition.Reason set to "PreconditionNotFulfilled"
+	// and any errors returned are shown as OperatorCondition.Message
+	Preconditions []deploymentcontroller.PreconditionFunc
+
 	// List of hooks should be run on the storage classes.
 	// No informers here, because StorageClassController does not accept any.
 	StorageClassHooks []csistorageclasscontroller.StorageClassHookFunc
@@ -116,6 +122,20 @@ func (o *OperatorControllerConfig) AddStorageClassHookBuilders(c *clients.Client
 	}
 }
 
+func (o *OperatorControllerConfig) AddPreconditions(preconditionFuncs ...deploymentcontroller.PreconditionFunc) {
+	for _, f := range preconditionFuncs {
+		o.Preconditions = append(o.Preconditions, f)
+	}
+}
+
+func (o *OperatorControllerConfig) GetPreconditions() []func(context.Context) (bool, error) {
+	var funcs []func(context.Context) (bool, error)
+	for _, precondition := range o.Preconditions {
+		funcs = append(funcs, precondition)
+	}
+	return funcs
+}
+
 type DeploymentHookBuilder func(c *clients.Clients) (deploymentcontroller.DeploymentHookFunc, []factory.Informer)
 type DaemonSetHookBuilder func(c *clients.Clients) (csidrivernodeservicecontroller.DaemonSetHookFunc, []factory.Informer)
 type StorageClassHookBuilder func(c *clients.Clients) csistorageclasscontroller.StorageClassHookFunc

pkg/operator/starter.go

@@ -113,13 +113,15 @@ func RunOperator(ctx context.Context, controllerConfig *controllercmd.Controller
 	).WithCSIConfigObserverController(
 		csiOperatorControllerConfig.GetControllerName("DriverCSIConfigObserverController"),
 		c.ConfigInformers,
-	).WithCSIDriverControllerService(
+	).WithCSIDriverControllerServiceWorkload(
 		csiOperatorControllerConfig.GetControllerName("DriverControllerServiceController"),
+		controlPlaneNamespace,
 		a.GetAsset,
 		generated_assets.ControllerDeploymentAssetName,
 		c.ControlPlaneKubeClient,
-		c.ControlPlaneKubeInformers.InformersFor(controlPlaneNamespace),
+		c.ControlPlaneKubeInformers,
 		c.ConfigInformers,
+		csiOperatorControllerConfig.GetPreconditions(),
 		controlPlaneControllerInformers,
 		controllerHooks...,
 	)