Documentation
¶
Index ¶
- type 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
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.
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
Source Files
Click to show internal directories.
Click to hide internal directories.