operator

Documentation

Index

• func NewCSIDriverOperator(client OperatorClient, ...) *csiDriverOperator
• func RunOperator(ctx context.Context, controllerConfig *controllercmd.ControllerContext) error
• type OperatorClient
  • func (c OperatorClient) GetOperatorInstance() (*v1alpha1.EBSCSIDriver, error)
  • func (c OperatorClient) GetOperatorState() (*operatorv1.OperatorSpec, *operatorv1.OperatorStatus, string, error)
  • func (c OperatorClient) Informer() cache.SharedIndexInformer
  • func (c OperatorClient) UpdateOperatorSpec(resourceVersion string, spec *operatorv1.OperatorSpec) (*operatorv1.OperatorSpec, string, error)
  • func (c OperatorClient) UpdateOperatorStatus(resourceVersion string, status *operatorv1.OperatorStatus) (*operatorv1.OperatorStatus, error)

Functions

func NewCSIDriverOperator

func NewCSIDriverOperator(
	client OperatorClient,
	crdInformer apiextinformersv1beta1.CustomResourceDefinitionInformer,
	crdClient apiextclient.Interface,
	deployInformer appsinformersv1.DeploymentInformer,
	kubeClient kubernetes.Interface,
	versionGetter status.VersionGetter,
	eventRecorder events.Recorder,
	operatorVersion string,
	operandVersion string,
	csiDriverImage string,
) *csiDriverOperator

func RunOperator

func RunOperator(ctx context.Context, controllerConfig *controllercmd.ControllerContext) error

Types

type OperatorClient

type OperatorClient struct {
	Informers informers.SharedInformerFactory
	Client    configset.EBSCSIDriversGetter
}

func (OperatorClient) GetOperatorInstance

func (c OperatorClient) GetOperatorInstance() (*v1alpha1.EBSCSIDriver, error)

func (OperatorClient) GetOperatorState

func (c OperatorClient) GetOperatorState() (*operatorv1.OperatorSpec, *operatorv1.OperatorStatus, string, error)

func (OperatorClient) Informer

func (c OperatorClient) Informer() cache.SharedIndexInformer

func (OperatorClient) UpdateOperatorSpec

func (c OperatorClient) UpdateOperatorSpec(resourceVersion string, spec *operatorv1.OperatorSpec) (*operatorv1.OperatorSpec, string, error)

func (OperatorClient) UpdateOperatorStatus

func (c OperatorClient) UpdateOperatorStatus(resourceVersion string, status *operatorv1.OperatorStatus) (*operatorv1.OperatorStatus, error)