csidriveroperator

Documentation

Index

• func NewCSIDriverOperatorCRController(name string, clients *csoclients.Clients, ...) factory.Controller
• func NewCSIDriverOperatorDeploymentController(clients *csoclients.Clients, ...) factory.Controller
• func NewHyperShiftControllerDeployment(mgtClient *csoclients.Clients, guestClient *csoclients.Clients, ...) factory.Controller
• func NewHypershiftDriverStarter(clients *csoclients.Clients, mgmtClients *csoclients.Clients, ...) (factory.Controller, *hypershiftDriverStarter)
• func NewStandaloneDriverStarter(clients *csoclients.Clients, featureGates featuregates.FeatureGate, ...) (factory.Controller, *standAloneDriverStarter)
• func RelatedObjectFunc() func() (isset bool, objs []configv1.ObjectReference)
• type CSIDriverOperatorCRController
  • 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
  • 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 HyperShiftDeploymentController
  • 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 RelatedObjectGetter

Functions

func NewCSIDriverOperatorCRController

func NewCSIDriverOperatorCRController(
	name string,
	clients *csoclients.Clients,
	csiOperatorConfig csioperatorclient.CSIOperatorConfig,
	eventRecorder events.Recorder,
	resyncInterval time.Duration,
) factory.Controller

func NewCSIDriverOperatorDeploymentController

func NewCSIDriverOperatorDeploymentController(
	clients *csoclients.Clients,
	csiOperatorConfig csioperatorclient.CSIOperatorConfig,
	versionGetter status.VersionGetter,
	targetVersion string,
	eventRecorder events.Recorder,
	resyncInterval time.Duration,
) factory.Controller

func NewHyperShiftControllerDeployment

func NewHyperShiftControllerDeployment(
	mgtClient *csoclients.Clients,
	guestClient *csoclients.Clients,
	controlNamespace string,
	csiOperatorConfig csioperatorclient.CSIOperatorConfig,
	versionGetter status.VersionGetter,
	targetVersion string,
	eventRecorder events.Recorder,
	resyncInterval time.Duration,
) factory.Controller

func NewHypershiftDriverStarter

func NewHypershiftDriverStarter(
	clients *csoclients.Clients,
	mgmtClients *csoclients.Clients,
	fg featuregates.FeatureGate,
	controlNamespace string,
	resyncInterval time.Duration,
	versionGetter status.VersionGetter,
	targetVersion string,
	eventRecorder events.Recorder,
	mgmtEventRecorder events.Recorder,
	driverConfigs []csioperatorclient.CSIOperatorConfig) (factory.Controller, *hypershiftDriverStarter)

func NewStandaloneDriverStarter

func NewStandaloneDriverStarter(
	clients *csoclients.Clients,
	featureGates featuregates.FeatureGate,
	resyncInterval time.Duration,
	versionGetter status.VersionGetter,
	targetVersion string,
	eventRecorder events.Recorder,
	driverConfigs []csioperatorclient.CSIOperatorConfig) (factory.Controller, *standAloneDriverStarter)

func RelatedObjectFunc

func RelatedObjectFunc() func() (isset bool, objs []configv1.ObjectReference)

Types

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 (*CSIDriverOperatorCRController) Name

func (c *CSIDriverOperatorCRController) Name() string

func (*CSIDriverOperatorCRController) Run

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

func (*CSIDriverOperatorCRController) Sync

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 (*CSIDriverOperatorDeploymentController) Name

func (c *CSIDriverOperatorDeploymentController) Name() string

func (*CSIDriverOperatorDeploymentController) Run

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

func (*CSIDriverOperatorDeploymentController) Sync

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 (*HyperShiftDeploymentController) Name

func (c *HyperShiftDeploymentController) Name() string

func (*HyperShiftDeploymentController) Run

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

func (*HyperShiftDeploymentController) Sync

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

type RelatedObjectGetter

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