controllers

Documentation

Index

• Constants
• func NewComponentDeleteManager(componentClient componentInterface, helmClient helmClient) *componentDeleteManager
• func NewComponentRequeueHandler(clientSet componentEcosystemInterface, recorder record.EventRecorder, ...) *componentRequeueHandler
• type ComponentInstallManager
  • func NewComponentInstallManager(componentClient componentInterface, helmClient helmClient, ...) *ComponentInstallManager
  • func (cim *ComponentInstallManager) Install(ctx context.Context, component *k8sv1.Component) error
• type ComponentManager
• type ComponentReconciler
  • func NewComponentReconciler(clientSet componentEcosystemInterface, helmClient helmClient, ...) *ComponentReconciler
  • func (r *ComponentReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *ComponentReconciler) SetupWithManager(mgr ctrl.Manager) error
• type ComponentUpgradeManager
  • func NewComponentUpgradeManager(componentClient componentInterface, helmClient helmClient, ...) *ComponentUpgradeManager
  • func (cum *ComponentUpgradeManager) Upgrade(ctx context.Context, component *k8sv1.Component) error
• type DefaultComponentManager
  • func NewComponentManager(clientset componentInterface, helmClient helmClient, ...) *DefaultComponentManager
  • func (m *DefaultComponentManager) Delete(ctx context.Context, component *k8sv1.Component) error
  • func (m *DefaultComponentManager) Install(ctx context.Context, component *k8sv1.Component) error
  • func (m *DefaultComponentManager) Upgrade(ctx context.Context, component *k8sv1.Component) error

Constants

const (
	// InstallEventReason The name of the installation event
	InstallEventReason = "Installation"
	// DeinstallationEventReason The name of the deinstallation event
	DeinstallationEventReason = "Deinstallation"
	// UpgradeEventReason The name of the upgrade event
	UpgradeEventReason = "Upgrade"
	// DowngradeEventReason The name of the downgrade event
	DowngradeEventReason = "Downgrade"
	// RequeueEventReason The name of the requeue event
	RequeueEventReason = "Requeue"
	// FailedNameValidationEventReason The name of the event to validate spec.name and metadata.name of a component.
	FailedNameValidationEventReason = "FailedNameValidation"
	// Install represents the install-operation
	Install = operation("Install")
	// Upgrade represents the upgrade-operation
	Upgrade = operation("Upgrade")
	// Downgrade represents the downgrade-operation. Currently not supported.
	Downgrade = operation("Downgrade")
	// Delete represents the delete-operation
	Delete = operation("Delete")
	// Ignore represents the ignore-operation
	Ignore = operation("Ignore")
)

Functions

func NewComponentDeleteManager

func NewComponentDeleteManager(componentClient componentInterface, helmClient helmClient) *componentDeleteManager

NewComponentDeleteManager creates a new instance of componentDeleteManager.

func NewComponentRequeueHandler

func NewComponentRequeueHandler(clientSet componentEcosystemInterface, recorder record.EventRecorder, namespace string) *componentRequeueHandler

NewComponentRequeueHandler creates a new component requeue handler.

Types

type ComponentInstallManager

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

ComponentInstallManager is a central unit in the process of handling the installation process of a custom dogu resource.

func NewComponentInstallManager

func NewComponentInstallManager(componentClient componentInterface, helmClient helmClient, healthManager healthManager, recorder record.EventRecorder) *ComponentInstallManager

NewComponentInstallManager creates a new instance of ComponentInstallManager.

func (*ComponentInstallManager) Install

func (cim *ComponentInstallManager) Install(ctx context.Context, component *k8sv1.Component) error

Install installs a given Component Resource. If no expected version is given in the component CR the latest version will be installed.

type ComponentManager

type ComponentManager interface {
	// contains filtered or unexported methods
}

ComponentManager abstracts the simple component operations in a k8s CES.

type ComponentReconciler

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

ComponentReconciler watches every Component object in the cluster and handles them accordingly.

func NewComponentReconciler

func NewComponentReconciler(clientSet componentEcosystemInterface, helmClient helmClient, recorder record.EventRecorder, namespace string) *ComponentReconciler

NewComponentReconciler creates a new component reconciler.

func (*ComponentReconciler) Reconcile

func (r *ComponentReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.

func (*ComponentReconciler) SetupWithManager

func (r *ComponentReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type ComponentUpgradeManager

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

ComponentUpgradeManager is a central unit in the process of handling the upgrade process of a custom component resource.

func NewComponentUpgradeManager

func NewComponentUpgradeManager(componentClient componentInterface, helmClient helmClient, healthManager healthManager, recorder record.EventRecorder) *ComponentUpgradeManager

NewComponentUpgradeManager creates a new instance of ComponentUpgradeManager.

func (*ComponentUpgradeManager) Upgrade

func (cum *ComponentUpgradeManager) Upgrade(ctx context.Context, component *k8sv1.Component) error

Upgrade upgrades a given component resource.

type DefaultComponentManager

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

DefaultComponentManager is a central unit in the process of handling component custom resources. The DefaultComponentManager creates, updates and deletes components.

func NewComponentManager

func NewComponentManager(clientset componentInterface, helmClient helmClient, healthManager healthManager, recorder record.EventRecorder) *DefaultComponentManager

NewComponentManager creates a new instance of DefaultComponentManager.

func (*DefaultComponentManager) Delete

func (m *DefaultComponentManager) Delete(ctx context.Context, component *k8sv1.Component) error

Delete deletes the given component resource.

func (*DefaultComponentManager) Install

func (m *DefaultComponentManager) Install(ctx context.Context, component *k8sv1.Component) error

Install installs the given component resource.

func (*DefaultComponentManager) Upgrade

func (m *DefaultComponentManager) Upgrade(ctx context.Context, component *k8sv1.Component) error

Upgrade upgrades the given component resource.