controllers

Documentation

Index

• Constants
• Variables
• type ContainerStorageModuleReconciler
  • func (r *ContainerStorageModuleReconciler) ContentWatch() error
  • func (r *ContainerStorageModuleReconciler) GetClient() client.Client
  • func (r *ContainerStorageModuleReconciler) GetK8sClient() kubernetes.Interface
  • func (r *ContainerStorageModuleReconciler) GetUpdateCount() int32
  • func (r *ContainerStorageModuleReconciler) IncrUpdateCount()
  • func (r *ContainerStorageModuleReconciler) PreChecks(ctx context.Context, cr *csmv1.ContainerStorageModule, ...) error
  • func (r *ContainerStorageModuleReconciler) Reconcile(_ context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *ContainerStorageModuleReconciler) SetupWithManager(mgr ctrl.Manager, limiter ratelimiter.RateLimiter, maxReconcilers int) error
  • func (r *ContainerStorageModuleReconciler) SyncCSM(ctx context.Context, cr csmv1.ContainerStorageModule, ...) error
• type DriverConfig

Constants

const (
	// MetadataPrefix - prefix for all labels & annotations
	MetadataPrefix = "storage.dell.com"

	// NodeYaml - yaml file name for node
	NodeYaml = "node.yaml"

	// CSMFinalizerName -
	CSMFinalizerName = "finalizer.dell.emc.com"

	// CSMVersion -
	CSMVersion = "v1.12.0"
)

Variables

var (

	// CSMVersionKey -
	CSMVersionKey = fmt.Sprintf("%s/%s", MetadataPrefix, "CSMVersion")

	// StopWatch - watcher stop handle
	StopWatch = make(chan struct{})
)

Types

type ContainerStorageModuleReconciler

type ContainerStorageModuleReconciler struct {
	// controller runtime client, responsible for create, delete, update, get etc.
	client.Client
	// k8s client, implements client-go/kubernetes interface, responsible for apply, which
	// client.Client does not provides
	K8sClient kubernetes.Interface
	Scheme    *runtime.Scheme
	Log       *zap.SugaredLogger
	Config    utils.OperatorConfig

	EventRecorder record.EventRecorder
	// contains filtered or unexported fields
}

ContainerStorageModuleReconciler reconciles a ContainerStorageModule object

func (*ContainerStorageModuleReconciler) ContentWatch

func (r *ContainerStorageModuleReconciler) ContentWatch() error

ContentWatch - watch updates on deployment and deamonset

func (*ContainerStorageModuleReconciler) GetClient

func (r *ContainerStorageModuleReconciler) GetClient() client.Client

GetClient - returns the split client

func (*ContainerStorageModuleReconciler) GetK8sClient

func (r *ContainerStorageModuleReconciler) GetK8sClient() kubernetes.Interface

GetK8sClient - Returns the current update count

func (*ContainerStorageModuleReconciler) GetUpdateCount

func (r *ContainerStorageModuleReconciler) GetUpdateCount() int32

GetUpdateCount - Returns the current update count

func (*ContainerStorageModuleReconciler) IncrUpdateCount

func (r *ContainerStorageModuleReconciler) IncrUpdateCount()

IncrUpdateCount - Increments the update count

func (*ContainerStorageModuleReconciler) PreChecks

func (r *ContainerStorageModuleReconciler) PreChecks(ctx context.Context, cr *csmv1.ContainerStorageModule, operatorConfig utils.OperatorConfig) error

PreChecks - validate input values

func (*ContainerStorageModuleReconciler) Reconcile

func (r *ContainerStorageModuleReconciler) Reconcile(_ context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile - main loop

func (*ContainerStorageModuleReconciler) SetupWithManager

func (r *ContainerStorageModuleReconciler) SetupWithManager(mgr ctrl.Manager, limiter ratelimiter.RateLimiter, maxReconcilers int) error

SetupWithManager sets up the controller with the Manager.

func (*ContainerStorageModuleReconciler) SyncCSM

func (r *ContainerStorageModuleReconciler) SyncCSM(ctx context.Context, cr csmv1.ContainerStorageModule, operatorConfig utils.OperatorConfig, ctrlClient client.Client) error

SyncCSM - Sync the current installation - this can lead to a create or update

type DriverConfig

type DriverConfig struct {
	Driver     *storagev1.CSIDriver
	ConfigMap  *corev1.ConfigMap
	Node       *utils.NodeYAML
	Controller *utils.ControllerYAML
}

DriverConfig -