reconcilers

Documentation

Index

• func CreateOnlyMutator(existing, desired k8sutils.KubernetesObject) (bool, error)
• func ReconcileEnvVar(existing *[]v1.EnvVar, desired []v1.EnvVar) bool
• func ServicePortMutator(existingObj, desiredObj k8sutils.KubernetesObject) (bool, error)
• type BaseControllerReconciler
  • func NewBaseControllerReconciler(client client.Client, apiClientReader client.Reader, scheme *runtime.Scheme) BaseControllerReconciler
  • func (r *BaseControllerReconciler) APIClientReader() client.Reader
  • func (r *BaseControllerReconciler) Client() client.Client
  • func (r *BaseControllerReconciler) Reconcile(context.Context, reconcile.Request) (reconcile.Result, error)
  • func (r *BaseControllerReconciler) Scheme() *runtime.Scheme
• type BaseReconciler
  • func NewBaseReconciler(client client.Client, apiClientReader client.Reader, scheme *runtime.Scheme, ...) BaseReconciler
  • func (b *BaseReconciler) APIClientReader() client.Reader
  • func (b *BaseReconciler) Client() client.Client
  • func (b *BaseReconciler) Logger() logr.Logger
  • func (b *BaseReconciler) ReconcileResource(ctx context.Context, obj, desired k8sutils.KubernetesObject, mutateFn MutateFn) error
  • func (b *BaseReconciler) Scheme() *runtime.Scheme
• type MutateFn

Functions

func CreateOnlyMutator

func CreateOnlyMutator(existing, desired k8sutils.KubernetesObject) (bool, error)

func ReconcileEnvVar

func ReconcileEnvVar(existing *[]v1.EnvVar, desired []v1.EnvVar) bool

ReconcileEnvVar reconciles environment var lists

func ServicePortMutator

func ServicePortMutator(existingObj, desiredObj k8sutils.KubernetesObject) (bool, error)

Types

type BaseControllerReconciler

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

func NewBaseControllerReconciler

func NewBaseControllerReconciler(client client.Client, apiClientReader client.Reader, scheme *runtime.Scheme) BaseControllerReconciler

func (*BaseControllerReconciler) APIClientReader

func (r *BaseControllerReconciler) APIClientReader() client.Reader

func (*BaseControllerReconciler) Client

func (r *BaseControllerReconciler) Client() client.Client

func (*BaseControllerReconciler) Reconcile

func (r *BaseControllerReconciler) Reconcile(context.Context, reconcile.Request) (reconcile.Result, error)

func (*BaseControllerReconciler) Scheme

func (r *BaseControllerReconciler) Scheme() *runtime.Scheme

type BaseReconciler

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

func NewBaseReconciler

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

func (*BaseReconciler) APIClientReader

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

func (*BaseReconciler) Client

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

func (*BaseReconciler) Logger

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

func (*BaseReconciler) ReconcileResource

func (b *BaseReconciler) ReconcileResource(ctx context.Context, obj, desired k8sutils.KubernetesObject, 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) Scheme

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

type MutateFn

type MutateFn func(existing, desired k8sutils.KubernetesObject) (bool, error)

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