csicontrollerset

Documentation

Index

• type CSIControllerSet
  • func NewCSIControllerSet(operatorClient v1helpers.OperatorClientWithFinalizers, ...) *CSIControllerSet
  • func (c *CSIControllerSet) Run(ctx context.Context, workers int)
  • func (c *CSIControllerSet) WithCSIConfigObserverController(name string, configinformers configinformers.SharedInformerFactory) *CSIControllerSet
  • func (c *CSIControllerSet) WithCSIDriverControllerService(name string, assetFunc resourceapply.AssetFunc, file string, ...) *CSIControllerSet
  • func (c *CSIControllerSet) WithCSIDriverNodeService(name string, assetFunc resourceapply.AssetFunc, file string, ...) *CSIControllerSet
  • func (c *CSIControllerSet) WithConditionalStaticResourcesController(name string, kubeClient kubernetes.Interface, dynamicClient dynamic.Interface, ...) *CSIControllerSet
  • func (c *CSIControllerSet) WithCredentialsRequestController(name string, operandNamespace string, assetFunc resourceapply.AssetFunc, ...) *CSIControllerSet
  • func (c *CSIControllerSet) WithLogLevelController() *CSIControllerSet
  • func (c *CSIControllerSet) WithManagementStateController(operandName string, supportsOperandRemoval bool) *CSIControllerSet
  • func (c *CSIControllerSet) WithServiceMonitorController(name string, dynamicClient dynamic.Interface, ...) *CSIControllerSet
  • func (c *CSIControllerSet) WithStaticResourcesController(name string, kubeClient kubernetes.Interface, dynamicClient dynamic.Interface, ...) *CSIControllerSet
  • func (c *CSIControllerSet) WithStorageClassController(name string, assetFunc resourceapply.AssetFunc, files []string, ...) *CSIControllerSet

Types

type CSIControllerSet

type CSIControllerSet struct {
	// contains filtered or unexported fields
}

CSIControllerSet contains a set of controllers that are usually used to deploy CSI Drivers.

func NewCSIControllerSet

func NewCSIControllerSet(operatorClient v1helpers.OperatorClientWithFinalizers, eventRecorder events.Recorder) *CSIControllerSet

New returns a basic *ControllerSet without any controller.

func (*CSIControllerSet) Run

func (c *CSIControllerSet) Run(ctx context.Context, workers int)

Run starts all controllers initialized in the set.

func (*CSIControllerSet) WithCSIConfigObserverController

func (c *CSIControllerSet) WithCSIConfigObserverController(
	name string,
	configinformers configinformers.SharedInformerFactory,
) *CSIControllerSet

func (*CSIControllerSet) WithCSIDriverControllerService

func (c *CSIControllerSet) WithCSIDriverControllerService(
	name string,
	assetFunc resourceapply.AssetFunc,
	file string,
	kubeClient kubernetes.Interface,
	namespacedInformerFactory informers.SharedInformerFactory,
	configInformer configinformers.SharedInformerFactory,
	optionalInformers []factory.Informer,
	optionalDeploymentHooks ...deploymentcontroller.DeploymentHookFunc,
) *CSIControllerSet

func (*CSIControllerSet) WithCSIDriverNodeService

func (c *CSIControllerSet) WithCSIDriverNodeService(
	name string,
	assetFunc resourceapply.AssetFunc,
	file string,
	kubeClient kubernetes.Interface,
	namespacedInformerFactory informers.SharedInformerFactory,
	optionalInformers []factory.Informer,
	optionalDaemonSetHooks ...csidrivernodeservicecontroller.DaemonSetHookFunc,
) *CSIControllerSet

func (*CSIControllerSet) WithConditionalStaticResourcesController

func (c *CSIControllerSet) WithConditionalStaticResourcesController(
	name string,
	kubeClient kubernetes.Interface,
	dynamicClient dynamic.Interface,
	kubeInformersForNamespace v1helpers.KubeInformersForNamespaces,
	manifests resourceapply.AssetFunc,
	files []string,
	shouldCreateFnArg, shouldDeleteFnArg resourceapply.ConditionalFunction,
) *CSIControllerSet

WithConditionalStaticResourcesController returns a *ControllerSet with a conditional static resources controller initialized. The func can be called multiple times to setup multiple controllers. The calls do not replace any existing controllers.

func (*CSIControllerSet) WithCredentialsRequestController

func (c *CSIControllerSet) WithCredentialsRequestController(
	name string,
	operandNamespace string,
	assetFunc resourceapply.AssetFunc,
	file string,
	dynamicClient dynamic.Interface,
	operatorInformer operatorinformer.SharedInformerFactory,
	hooks ...credentialsrequestcontroller.CredentialsRequestHook,
) *CSIControllerSet

WithCredentialsRequestController returns a *ControllerSet with a CredentialsRequestController initialized.

func (*CSIControllerSet) WithLogLevelController

func (c *CSIControllerSet) WithLogLevelController() *CSIControllerSet

WithLogLevelController returns a *ControllerSet with a log level controller initialized.

func (*CSIControllerSet) WithManagementStateController

func (c *CSIControllerSet) WithManagementStateController(operandName string, supportsOperandRemoval bool) *CSIControllerSet

WithManagementStateController returns a *ControllerSet with a management state controller initialized.

func (*CSIControllerSet) WithServiceMonitorController

func (c *CSIControllerSet) WithServiceMonitorController(
	name string,
	dynamicClient dynamic.Interface,
	assetFunc resourceapply.AssetFunc,
	file string,
) *CSIControllerSet

WithServiceMonitorController returns a *ControllerSet that creates ServiceMonitor.

func (*CSIControllerSet) WithStaticResourcesController

func (c *CSIControllerSet) WithStaticResourcesController(
	name string,
	kubeClient kubernetes.Interface,
	dynamicClient dynamic.Interface,
	kubeInformersForNamespace v1helpers.KubeInformersForNamespaces,
	manifests resourceapply.AssetFunc,
	files []string,
) *CSIControllerSet

WithStaticResourcesController returns a *ControllerSet with a static resources controller initialized.

func (*CSIControllerSet) WithStorageClassController

func (c *CSIControllerSet) WithStorageClassController(
	name string,
	assetFunc resourceapply.AssetFunc,
	files []string,
	kubeClient kubernetes.Interface,
	namespacedInformerFactory informers.SharedInformerFactory,
	operatorInformer operatorinformer.SharedInformerFactory,
	hooks ...csistorageclasscontroller.StorageClassHookFunc,
) *CSIControllerSet