controllers

package
v1.2.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 12, 2024 License: MIT Imports: 48 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// AdditionalIngressAnnotationsChangeEventReason is the reason string for firing additional ingress annotations change events.
	AdditionalIngressAnnotationsChangeEventReason = "AdditionalIngressAnnotationsChange"
	// ErrorOnAdditionalIngressAnnotationsChangeEventReason is the error string for firing additional ingress annotations change error events.
	ErrorOnAdditionalIngressAnnotationsChangeEventReason = "ErrAdditionalIngressAnnotationsChange"
)
View Source 
const (
	// StartDoguEventReason is the reason string for firing start dogu events.
	StartDoguEventReason = "StartDogu"
	// ErrorOnStartDoguEventReason is the error string for firing start dogu error events.
	ErrorOnStartDoguEventReason = "ErrStartDogu"

	// StopDoguEventReason is the reason string for firing stop dogu events.
	StopDoguEventReason = "StopDogu"
	// ErrorOnStopDoguEventReason is the error string for firing stop dogu error events.
	ErrorOnStopDoguEventReason     = "ErrStopDogu"
	CheckStartedEventReason        = "CheckStarted"
	ErrorOnCheckStartedEventReason = "ErrCheckStarted"
	CheckStoppedEventReason        = "CheckStopped"
	ErrorOnCheckStoppedEventReason = "ErrCheckStopped"
)
View Source 
const (
	// VolumeExpansionEventReason is the reason string for firing volume expansion events.
	VolumeExpansionEventReason = "VolumeExpansion"
	// ErrorOnVolumeExpansionEventReason is the error string for firing volume expansion error events.
	ErrorOnVolumeExpansionEventReason = "ErrVolumeExpansion"
)
View Source 
const (
	InstallEventReason        = "Installation"
	ErrorOnInstallEventReason = "ErrInstallation"
)
View Source 
const (
	DeinstallEventReason      = "Deinstallation"
	ErrorDeinstallEventReason = "ErrDeinstallation"
)
View Source 
const (
	SupportEventReason        = "Support"
	ErrorOnSupportEventReason = "ErrSupport"
)
View Source 
const (
	RequeueEventReason        = "Requeue"
	ErrorOnRequeueEventReason = "ErrRequeue"
)
View Source 
const (
	FailedNameValidationEventReason              = "FailedNameValidation"
	FailedVolumeSizeParsingValidationEventReason = "FailedVolumeSizeParsingValidation"
	FailedVolumeSizeSIValidationEventReason      = "FailedVolumeSizeSIValidation"
)
View Source 
const (
	Install                            = operation("Install")
	Upgrade                            = operation("Upgrade")
	Delete                             = operation("Delete")
	Wait                               = operation("Wait")
	ExpandVolume                       = operation("ExpandVolume")
	ChangeAdditionalIngressAnnotations = operation("ChangeAdditionalIngressAnnotations")
	StartDogu                          = operation("StartDogu")
	StopDogu                           = operation("StopDogu")
	CheckStarted                       = operation("CheckStarted")
	CheckStopped                       = operation("CheckStopped")
)
View Source 
const SupportModeEnvVar = "SUPPORT_MODE"

Variables

View Source 
var NewManager = NewDoguManager

NewManager is an alias mainly used for testing the main package

Functions

func NewDoguAdditionalIngressAnnotationsManager added in v0.29.0 

func NewDoguAdditionalIngressAnnotationsManager(client client.Client, eventRecorder record.EventRecorder) *doguAdditionalIngressAnnotationsManager

NewDoguAdditionalIngressAnnotationsManager creates a new instance of a manager to append ingress annotations to a dogu service.

func NewDoguDeleteManager added in v0.9.0 

func NewDoguDeleteManager(
	client client.Client,
	operatorConfig *config.OperatorConfig,
	cesRegistry cesregistry.Registry,
	mgrSet *util.ManagerSet,
	recorder record.EventRecorder,
) *doguDeleteManager

NewDoguDeleteManager creates a new instance of doguDeleteManager.

func NewDoguInstallManager added in v0.9.0 

func NewDoguInstallManager(client client.Client, cesRegistry cesregistry.Registry, mgrSet *util.ManagerSet, eventRecorder record.EventRecorder) *doguInstallManager

NewDoguInstallManager creates a new instance of doguInstallManager.

func NewDoguReconciler 

func NewDoguReconciler(client client.Client, doguInterface ecoSystem.DoguInterface, doguManager cloudogu.DoguManager, eventRecorder record.EventRecorder, namespace string, localDoguRegistry local.LocalDoguRegistry) (*doguReconciler, error)

NewDoguReconciler creates a new reconciler instance for the dogu resource

func NewDoguRequeueHandler added in v0.3.0 

func NewDoguRequeueHandler(doguInterface ecoSystem.DoguInterface, recorder record.EventRecorder, namespace string) (*doguRequeueHandler, error)

NewDoguRequeueHandler creates a new dogu requeue handler.

func NewDoguSupportManager added in v0.13.0 

func NewDoguSupportManager(client client.Client, mgrSet *util.ManagerSet, eventRecorder record.EventRecorder) *doguSupportManager

NewDoguSupportManager creates a new instance of doguSupportManager.

func NewDoguUpgradeManager added in v0.12.0 

func NewDoguUpgradeManager(client client.Client, mgrSet *util.ManagerSet, eventRecorder record.EventRecorder) *doguUpgradeManager

NewDoguUpgradeManager creates a new instance of doguUpgradeManager which handles dogu upgrades.

func NewDoguVolumeManager added in v0.19.0 

func NewDoguVolumeManager(client client.Client, eventRecorder record.EventRecorder) *doguVolumeManager

NewDoguVolumeManager creates a new instance of the doguVolumeManager.

Types

type DeploymentReconciler added in v0.40.0 

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

DeploymentReconciler watches every Deployment object in the cluster and writes the state of dogus into their respective custom resources.

func NewDeploymentReconciler added in v0.40.0 

func NewDeploymentReconciler(k8sClientSet thirdParty.ClientSet, availabilityChecker *health.AvailabilityChecker,
	doguHealthStatusUpdater cloudogu.DoguHealthStatusUpdater, localDoguRegistry *local.CombinedLocalDoguRegistry) *DeploymentReconciler

func (*DeploymentReconciler) Reconcile added in v0.40.0 

func (dr *DeploymentReconciler) Reconcile(ctx context.Context, request 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 (*DeploymentReconciler) SetupWithManager added in v0.40.0 

func (dr *DeploymentReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type DoguManager 

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

DoguManager is a central unit in the process of handling dogu custom resources The DoguManager creates, updates and deletes dogus

func NewDoguManager 

func NewDoguManager(client client.Client, ecosystemClient ecoSystem.EcoSystemV1Alpha1Interface, operatorConfig *config.OperatorConfig, cesRegistry cesregistry.Registry, eventRecorder record.EventRecorder) (*DoguManager, error)

NewDoguManager creates a new instance of DoguManager

func (*DoguManager) CheckStarted added in v1.0.0 

func (m *DoguManager) CheckStarted(ctx context.Context, doguResource *k8sv1.Dogu) error

func (*DoguManager) CheckStopped added in v1.0.0 

func (m *DoguManager) CheckStopped(ctx context.Context, doguResource *k8sv1.Dogu) error

func (*DoguManager) Delete 

func (m *DoguManager) Delete(ctx context.Context, doguResource *k8sv1.Dogu) error

Delete deletes a dogu resource.

func (*DoguManager) HandleSupportMode added in v0.13.0 

func (m *DoguManager) HandleSupportMode(ctx context.Context, doguResource *k8sv1.Dogu) (bool, error)

HandleSupportMode handles the support flag in the dogu spec.

func (*DoguManager) Install 

func (m *DoguManager) Install(ctx context.Context, doguResource *k8sv1.Dogu) error

Install installs a dogu resource.

func (*DoguManager) SetDoguAdditionalIngressAnnotations added in v0.29.0 

func (m *DoguManager) SetDoguAdditionalIngressAnnotations(ctx context.Context, doguResource *k8sv1.Dogu) error

SetDoguAdditionalIngressAnnotations edits the additional ingress annotations in the given dogu's service.

func (*DoguManager) SetDoguDataVolumeSize added in v0.19.0 

func (m *DoguManager) SetDoguDataVolumeSize(ctx context.Context, doguResource *k8sv1.Dogu) error

SetDoguDataVolumeSize sets the dataVolumeSize from the dogu resource to the data PVC from the dogu.

func (*DoguManager) StartDogu added in v1.0.0 

func (m *DoguManager) StartDogu(ctx context.Context, doguResource *k8sv1.Dogu) error

StartDogu scales a stopped dogu to 1.

func (*DoguManager) StopDogu added in v1.0.0 

func (m *DoguManager) StopDogu(ctx context.Context, doguResource *k8sv1.Dogu) error

StopDogu scales a running dogu to 0.

func (*DoguManager) Upgrade 

func (m *DoguManager) Upgrade(ctx context.Context, doguResource *k8sv1.Dogu) error

Upgrade upgrades a dogu resource.

type DoguRestartGarbageCollector added in v1.0.0 

type DoguRestartGarbageCollector interface {
	DoGarbageCollection(ctx context.Context, doguName string) error
}

type DoguRestartReconciler added in v1.0.0 

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

DoguRestartReconciler reconciles a DoguRestart object

func NewDoguRestartReconciler added in v1.0.0 

func NewDoguRestartReconciler(doguRestartInterface ecoSystem.DoguRestartInterface, doguInterface ecoSystem.DoguInterface, recorder record.EventRecorder, gc DoguRestartGarbageCollector) *DoguRestartReconciler

func (*DoguRestartReconciler) Reconcile added in v1.0.0 

func (r *DoguRestartReconciler) 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.

For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.14.4/pkg/reconcile

func (*DoguRestartReconciler) SetupWithManager added in v1.0.0 

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

SetupWithManager sets up the controller with the Manager.

type RestartOperation added in v1.0.0 

type RestartOperation string

func RestartOperationFromRestartStatusPhase added in v1.0.0 

func RestartOperationFromRestartStatusPhase(phase k8sv1.RestartStatusPhase) RestartOperation

Source Files

View all Source files

Directories

Path Synopsis
loadbalancer
nginx

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.