reconcilers

Documentation

Index

• func ConfigMapReconcileField(desired, existing *v1.ConfigMap, fieldName string) bool
• func CreateOnlyMutator(existing, desired common.KubernetesObject) (bool, error)
• func DefaultsOnlySecretMutator(existingObj, desiredObj common.KubernetesObject) (bool, error)
• func DeploymentConfigAffinityReconciler(desired, existing *appsv1.DeploymentConfig) bool
• func DeploymentConfigContainerResourcesReconciler(desired, existing *appsv1.DeploymentConfig) bool
• func DeploymentConfigReplicasReconciler(desired, existing *appsv1.DeploymentConfig) bool
• func DeploymentConfigResourcesAndAffinityAndTolerationsMutator(existingObj, desiredObj common.KubernetesObject) (bool, error)
• func DeploymentConfigResourcesMutator(existingObj, desiredObj common.KubernetesObject) (bool, error)
• func DeploymentConfigTolerationsReconciler(desired, existing *appsv1.DeploymentConfig) bool
• func GenericDeploymentConfigMutator(existingObj, desiredObj common.KubernetesObject) (bool, error)
• func GenericImageStreamMutator(existingObj, desiredObj common.KubernetesObject) (bool, error)
• func GenericPDBMutator(existingObj, desiredObj common.KubernetesObject) (bool, error)
• func SecretReconcileField(desired, existing *v1.Secret, fieldName string) bool
• type BaseReconciler
  • func NewBaseReconciler(client client.Client, scheme *runtime.Scheme, apiClientReader client.Reader, ...) *BaseReconciler
  • func (b *BaseReconciler) APIClientReader() client.Reader
  • func (b *BaseReconciler) Client() client.Client
  • func (b *BaseReconciler) Context() context.Context
  • func (b *BaseReconciler) CreateResource(obj common.KubernetesObject) error
  • func (b *BaseReconciler) DeleteResource(obj common.KubernetesObject, options ...client.DeleteOption) error
  • func (b *BaseReconciler) DiscoveryClient() discovery.DiscoveryInterface
  • func (b *BaseReconciler) EventRecorder() record.EventRecorder
  • func (b *BaseReconciler) GetResource(objKey types.NamespacedName, obj common.KubernetesObject) error
  • func (b *BaseReconciler) Logger() logr.Logger
  • func (b *BaseReconciler) Reconcile(reconcile.Request) (reconcile.Result, error)
  • func (b *BaseReconciler) ReconcileResource(obj, desired common.KubernetesObject, mutateFn MutateFn) error
  • func (b *BaseReconciler) Scheme() *runtime.Scheme
  • func (b *BaseReconciler) UpdateResource(obj common.KubernetesObject) error
  • func (b *BaseReconciler) UpdateResourceStatus(obj common.KubernetesObject) error
• type MutateFn

Functions

func ConfigMapReconcileField

func ConfigMapReconcileField(desired, existing *v1.ConfigMap, fieldName string) bool

func CreateOnlyMutator

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

func DefaultsOnlySecretMutator

func DefaultsOnlySecretMutator(existingObj, desiredObj common.KubernetesObject) (bool, error)

DefaultsOnlySecretMutator is useful for secrets pre-created by the user and when not all the fields are created. Fields referenced from deployment configs must exist, so defaults only reconciliation makes sure they exist with default values when user does doe pre-create them

func DeploymentConfigAffinityReconciler

func DeploymentConfigAffinityReconciler(desired, existing *appsv1.DeploymentConfig) bool

func DeploymentConfigContainerResourcesReconciler

func DeploymentConfigContainerResourcesReconciler(desired, existing *appsv1.DeploymentConfig) bool

func DeploymentConfigReplicasReconciler

func DeploymentConfigReplicasReconciler(desired, existing *appsv1.DeploymentConfig) bool

func DeploymentConfigResourcesAndAffinityAndTolerationsMutator

func DeploymentConfigResourcesAndAffinityAndTolerationsMutator(existingObj, desiredObj common.KubernetesObject) (bool, error)

func DeploymentConfigResourcesMutator

func DeploymentConfigResourcesMutator(existingObj, desiredObj common.KubernetesObject) (bool, error)

func DeploymentConfigTolerationsReconciler

func DeploymentConfigTolerationsReconciler(desired, existing *appsv1.DeploymentConfig) bool

func GenericDeploymentConfigMutator

func GenericDeploymentConfigMutator(existingObj, desiredObj common.KubernetesObject) (bool, error)

func GenericImageStreamMutator

func GenericImageStreamMutator(existingObj, desiredObj common.KubernetesObject) (bool, error)

func GenericPDBMutator

func GenericPDBMutator(existingObj, desiredObj common.KubernetesObject) (bool, error)

func SecretReconcileField

func SecretReconcileField(desired, existing *v1.Secret, fieldName string) 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,
	ctx context.Context, logger logr.Logger, discoveryClient discovery.DiscoveryInterface, 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) Context

func (b *BaseReconciler) Context() context.Context

func (*BaseReconciler) CreateResource

func (b *BaseReconciler) CreateResource(obj common.KubernetesObject) error

func (*BaseReconciler) DeleteResource

func (b *BaseReconciler) DeleteResource(obj common.KubernetesObject, options ...client.DeleteOption) error

func (*BaseReconciler) DiscoveryClient

func (b *BaseReconciler) DiscoveryClient() discovery.DiscoveryInterface

func (*BaseReconciler) EventRecorder

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

func (*BaseReconciler) GetResource

func (b *BaseReconciler) GetResource(objKey types.NamespacedName, obj common.KubernetesObject) error

func (*BaseReconciler) Logger

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

func (*BaseReconciler) Reconcile

func (b *BaseReconciler) Reconcile(reconcile.Request) (reconcile.Result, error)

func (*BaseReconciler) ReconcileResource

func (b *BaseReconciler) ReconcileResource(obj, desired common.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

func (*BaseReconciler) UpdateResource

func (b *BaseReconciler) UpdateResource(obj common.KubernetesObject) error

func (*BaseReconciler) UpdateResourceStatus

func (b *BaseReconciler) UpdateResourceStatus(obj common.KubernetesObject) error

type MutateFn

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

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