csidriveroperator

type CSIDriverOperatorCRController ¶

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

This CSIDriverOperatorCRController installs and syncs CSI driver operator CR. It monitors the CR status and merges all its conditions to the CSO CR. It produces following Conditions: <CSI driver name>CSIDriverOperatorDegraded on error <CSI driver name>CSIDriverOperatorCRDegraded - copied from *Degraded conditions from CR. <CSI driver name>CSIDriverOperatorCRAvailable - copied from *Available conditions from CR. <CSI driver name>CSIDriverOperatorCRProgressing - copied from *Progressing conditions from CR.

func (c *CSIDriverOperatorCRController) Name() string

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

func (c *CSIDriverOperatorCRController) Sync(ctx context.Context, syncCtx factory.SyncContext) error

type CSIDriverOperatorDeploymentController ¶

type CSIDriverOperatorDeploymentController struct {
	CommonCSIDeploymentController
}

This CSIDriverStarterController installs and syncs CSI driver operator Deployment. It replace ${LOG_LEVEL} in the Deployment with current log level. It replaces images in the Deployment using CSIOperatorConfig.ImageReplacer. It produces following Conditions: <CSI driver name>CSIDriverOperatorDeploymentProgressing <CSI driver name>CSIDriverOperatorDeploymentDegraded This controller doesn't set the Available condition to avoid prematurely cascading up to the clusteroperator CR a potential Available=false. On the other hand it does a better in making sure the Degraded condition is properly set if Deployment isn't healthy.

func (c *CSIDriverOperatorDeploymentController) Name() string

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

func (c *CSIDriverOperatorDeploymentController) Sync(ctx context.Context, syncCtx factory.SyncContext) error

type CommonCSIDeploymentController ¶

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

type HyperShiftDeploymentController ¶

type HyperShiftDeploymentController struct {
	CommonCSIDeploymentController
	// contains filtered or unexported fields
}

This HyperShiftDeploymentController installs and syncs CSI driver operator Deployment. It replace ${LOG_LEVEL} in the Deployment with current log level. It replaces images in the Deployment using CSIOperatorConfig.ImageReplacer. It produces following Conditions: <CSI driver name>CSIDriverOperatorDeploymentProgressing <CSI driver name>CSIDriverOperatorDeploymentDegraded This controller doesn't set the Available condition to avoid prematurely cascading up to the clusteroperator CR a potential Available=false. On the other hand it does a better in making sure the Degraded condition is properly set if the Deployment isn't healthy.

func (c *HyperShiftDeploymentController) Name() string

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

func (c *HyperShiftDeploymentController) Sync(ctx context.Context, syncCtx factory.SyncContext) error

type OLMOperatorRemovalController ¶

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

This OLMOperatorRemovalController deletes pre-existing CSI driver installed by OLM to new CSI driver namespace. Steps performed:

1. Remove old OLM Subscription and CSV. Remember the operator namespace (in Storage CR annotation), just in case the controller is restarted after Subscription removal.
3. Remove the old CR (incl. force-removing all of its finalizers).

It produces following conditions: <CSI driver name>OLMOperatorRemovalProgressing/Degraded: for status reporting. <CSI driver name>OLMOperatorRemovalAvailable: to signal that the removal has been complete

func NewOLMOperatorRemovalController(
	csiOperatorConfig csioperatorclient.CSIOperatorConfig,
	clients *csoclients.Clients,
	eventRecorder events.Recorder,
	resyncInterval time.Duration,
) *OLMOperatorRemovalController

func (c *OLMOperatorRemovalController) Name() string

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

func (c *OLMOperatorRemovalController) Sync(ctx context.Context, syncCtx factory.SyncContext) error

type RelatedObjectGetter ¶

type RelatedObjectGetter interface {
	RelatedObjects() ([]configv1.ObjectReference, error)
}