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 (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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ConfigMapReconcileField ¶
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)
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) 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