csicontrollerset

package
v0.0.0-...-e158d5a Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 18, 2024 License: Apache-2.0 Imports: 23 Imported by: 19

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL