reconcilers

package
v0.9.0 Latest Latest
Warning

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

 Go to latest Published: May 27, 2024 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CreateOnlyMutator 

func CreateOnlyMutator(_, _ client.Object) (bool, error)

func DeploymentAffinityMutator added in v0.6.0 

func DeploymentAffinityMutator(desired, existing *appsv1.Deployment) bool

func DeploymentCommandMutator added in v0.5.0 

func DeploymentCommandMutator(desired, existing *appsv1.Deployment) bool

func DeploymentContainerListMutator added in v0.6.0 

func DeploymentContainerListMutator(desired, existing *appsv1.Deployment) bool

func DeploymentEnvMutator added in v0.7.0 

func DeploymentEnvMutator(desired, existing *appsv1.Deployment) bool

func DeploymentImageMutator added in v0.4.0 

func DeploymentImageMutator(desired, existing *appsv1.Deployment) bool

func DeploymentLivenessProbeMutator added in v0.8.0 

func DeploymentLivenessProbeMutator(desired, existing *appsv1.Deployment) bool

func DeploymentPortsMutator added in v0.8.0 

func DeploymentPortsMutator(desired, existing *appsv1.Deployment) bool

func DeploymentReadinessProbeMutator added in v0.8.0 

func DeploymentReadinessProbeMutator(desired, existing *appsv1.Deployment) bool

func DeploymentReplicasMutator added in v0.4.0 

func DeploymentReplicasMutator(desired, existing *appsv1.Deployment) bool

func DeploymentResourcesMutator added in v0.6.0 

func DeploymentResourcesMutator(desired, existing *appsv1.Deployment) bool

func DeploymentVolumeMountsMutator added in v0.7.0 

func DeploymentVolumeMountsMutator(desired, existing *appsv1.Deployment) bool

DeploymentVolumesMutator implements strict VolumeMounts reconcilliation Does not allow manually added volumeMounts

func DeploymentVolumesMutator added in v0.7.0 

func DeploymentVolumesMutator(desired, existing *appsv1.Deployment) bool

DeploymentVolumesMutator implements strict Volumes reconcilliation Does not allow manually added volumes

func PodDisruptionBudgetMutator added in v0.6.0 

func PodDisruptionBudgetMutator(existingObj, desiredObj client.Object) (bool, error)

func ServicePortsMutator added in v0.8.0 

func ServicePortsMutator(desired, existing *v1.Service) bool

Types

type BaseReconciler 

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

func NewBaseReconciler 

func NewBaseReconciler(
	client client.Client, scheme *runtime.Scheme, apiClientReader client.Reader,
	logger logr.Logger, recorder record.EventRecorder) *BaseReconciler

func (*BaseReconciler) APIClientReader 

func (b *BaseReconciler) APIClientReader() client.Reader

APIClientReader return a client that directly reads objects from the Kubernetes APIServer

func (*BaseReconciler) Client 

func (b *BaseReconciler) Client() client.Client

Client returns a split client that reads objects from the cache and writes to the Kubernetes APIServer

func (*BaseReconciler) CreateResource 

func (b *BaseReconciler) CreateResource(ctx context.Context, obj client.Object) error

func (*BaseReconciler) DeleteResource 

func (b *BaseReconciler) DeleteResource(ctx context.Context, obj client.Object, options ...client.DeleteOption) error

func (*BaseReconciler) EnsureOwnerReference 

func (b *BaseReconciler) EnsureOwnerReference(owner, obj client.Object) (bool, error)

EnsureOwnerReference sets owner as a Controller OwnerReference on owned returns boolean to notify when the object has been updated

func (*BaseReconciler) EventRecorder 

func (b *BaseReconciler) EventRecorder() record.EventRecorder

func (*BaseReconciler) GetResource 

func (b *BaseReconciler) GetResource(ctx context.Context, objKey types.NamespacedName, obj client.Object) error

func (*BaseReconciler) Logger 

func (b *BaseReconciler) Logger() logr.Logger

func (*BaseReconciler) Reconcile 

func (b *BaseReconciler) Reconcile(context.Context, ctrl.Request) (ctrl.Result, error)

func (*BaseReconciler) ReconcileConfigMap 

func (b *BaseReconciler) ReconcileConfigMap(ctx context.Context, desired *corev1.ConfigMap, mutatefn MutateFn) error

func (*BaseReconciler) ReconcileDeployment 

func (b *BaseReconciler) ReconcileDeployment(ctx context.Context, desired *appsv1.Deployment, mutatefn MutateFn) error

func (*BaseReconciler) ReconcilePersistentVolumeClaim added in v0.7.0 

func (b *BaseReconciler) ReconcilePersistentVolumeClaim(ctx context.Context, desired *corev1.PersistentVolumeClaim, mutatefn MutateFn) error

func (*BaseReconciler) ReconcilePodDisruptionBudget added in v0.6.0 

func (b *BaseReconciler) ReconcilePodDisruptionBudget(ctx context.Context, desired *policyv1.PodDisruptionBudget, mutatefn MutateFn) error

func (*BaseReconciler) ReconcileResource 

func (b *BaseReconciler) ReconcileResource(ctx context.Context, obj, desired client.Object, mutateFn MutateFn) error

ReconcileResource attempts to mutate the existing state in order to match the desired state. The object's desired state must be reconciled with the existing state inside the passed in callback MutateFn.

obj: Object of the same type as the 'desired' object. 

Used to read the resource from the kubernetes cluster.
Could be zero-valued initialized object.

desired: Object representing the desired state

It returns an error.

func (*BaseReconciler) ReconcileService 

func (b *BaseReconciler) ReconcileService(ctx context.Context, desired *corev1.Service, mutatefn MutateFn) error

func (*BaseReconciler) Scheme 

func (b *BaseReconciler) Scheme() *runtime.Scheme

func (*BaseReconciler) SetOwnerReference 

func (b *BaseReconciler) SetOwnerReference(owner, obj client.Object) error

SetOwnerReference sets owner as a Controller OwnerReference on owned

func (*BaseReconciler) UpdateResource 

func (b *BaseReconciler) UpdateResource(ctx context.Context, obj client.Object) error

func (*BaseReconciler) UpdateResourceStatus 

func (b *BaseReconciler) UpdateResourceStatus(ctx context.Context, obj client.Object) error

type DeploymentMutateFn added in v0.4.0 

type DeploymentMutateFn func(desired, existing *appsv1.Deployment) bool

DeploymentMutateFn is a function which mutates the existing Deployment into it's desired state.

type MutateFn 

type MutateFn func(existing, desired client.Object) (bool, error)

MutateFn is a function which mutates the existing object into it's desired state.

func DeploymentMutator added in v0.4.0 

func DeploymentMutator(opts ...DeploymentMutateFn) MutateFn

func ServiceMutator added in v0.8.0 

func ServiceMutator(opts ...ServiceMutateFn) MutateFn

type ServiceMutateFn added in v0.8.0 

type ServiceMutateFn func(desired, existing *v1.Service) bool

ServiceMutateFn is a function which mutates the existing Service into it's desired state.

Source Files

View all Source files

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.