reconciler

Documentation

Overview

Package reconciler provide runtime client function wrap

Index

• func AddPVCRetentionMark(c client.Client, ctx context.Context, namespace string, ...) (err error)
• func ApplyConfigMap(c client.Client, ctx context.Context, data *corev1.ConfigMap, ...) (err error)
• func ApplyCronJob(c client.Client, ctx context.Context, data *batchv1.CronJob, ...) (err error)
• func ApplyDeployment(c client.Client, ctx context.Context, data *appsv1.Deployment, ...) (err error)
• func ApplySecret(c client.Client, ctx context.Context, data *corev1.Secret, ...) (err error)
• func ApplyService(c client.Client, ctx context.Context, data *corev1.Service, ...) (err error)
• func ApplyStatefulSet(c client.Client, ctx context.Context, data *appsv1.StatefulSet, ...) (err error)
• func BuildCRPVCLabels(metaObj metav1.Object, obj runtime.Object) map[string]string
• func CheckOwnerRefExists(owner metav1.Object, refs []metav1.OwnerReference) (refExists bool)
• func DeleteSubResource(c client.Client, ctx context.Context, cr metav1.Object, ...) (err error)
• func RemovePVCRetentionMark(c client.Client, ctx context.Context, namespace string, ...) (err error)
• type PVCCleaner
  • func (t *PVCCleaner) Create(event.CreateEvent, workqueue.RateLimitingInterface)
  • func (t *PVCCleaner) Delete(event.DeleteEvent, workqueue.RateLimitingInterface)
  • func (t *PVCCleaner) Generic(event.GenericEvent, workqueue.RateLimitingInterface)
  • func (t *PVCCleaner) Update(evt event.UpdateEvent, wq workqueue.RateLimitingInterface)

Functions

func AddPVCRetentionMark

func AddPVCRetentionMark(c client.Client, ctx context.Context, namespace string, labelSelector map[string]string) (err error)

AddPVCRetentionMark add deadline annottion to pvc

func ApplyConfigMap

func ApplyConfigMap(c client.Client, ctx context.Context, data *corev1.ConfigMap, parentObject metav1.Object, scheme *runtime.Scheme) (err error)

ApplyConfigMap apply statefulset

func ApplyCronJob

func ApplyCronJob(c client.Client, ctx context.Context, data *batchv1.CronJob, parentObject metav1.Object, scheme *runtime.Scheme) (err error)

ApplyCronJob apply conjob

func ApplyDeployment

func ApplyDeployment(c client.Client, ctx context.Context, data *appsv1.Deployment, parentObject metav1.Object, scheme *runtime.Scheme) (err error)

func ApplySecret

func ApplySecret(c client.Client, ctx context.Context, data *corev1.Secret, parentObject metav1.Object, scheme *runtime.Scheme) (err error)

ApplySecret apply secret

func ApplyService

func ApplyService(c client.Client, ctx context.Context, data *corev1.Service, parentObject metav1.Object, scheme *runtime.Scheme) (err error)

ApplyService apply service

func ApplyStatefulSet

func ApplyStatefulSet(c client.Client, ctx context.Context, data *appsv1.StatefulSet, parentObject metav1.Object, scheme *runtime.Scheme) (err error)

ApplyStatefulSet apply statefulset

func BuildCRPVCLabels

func BuildCRPVCLabels(metaObj metav1.Object, obj runtime.Object) map[string]string

BuildCRPVCLabels generate CR subresource pvc labels

func CheckOwnerRefExists

func CheckOwnerRefExists(owner metav1.Object, refs []metav1.OwnerReference) (refExists bool)

CheckOwnerRefExists check onwer reference exists

func DeleteSubResource

func DeleteSubResource(c client.Client, ctx context.Context, cr metav1.Object, list ...client.ObjectList) (err error)

DeleteSubResource delete CR instance sub resources Notice: argument [ list ] will store data, so don't make reference to them for gc

func RemovePVCRetentionMark

func RemovePVCRetentionMark(c client.Client, ctx context.Context, namespace string, labelSelector map[string]string) (err error)

RemovePVCRetentionMark delete deadline annottion from pvc

Types

type PVCCleaner

type PVCCleaner struct {
}

func (*PVCCleaner) Create

func (t *PVCCleaner) Create(event.CreateEvent, workqueue.RateLimitingInterface)

Create is called in response to an create event - e.g. Pod Creation.

func (*PVCCleaner) Delete

func (t *PVCCleaner) Delete(event.DeleteEvent, workqueue.RateLimitingInterface)

Delete is called in response to a delete event - e.g. Pod Deleted.

func (*PVCCleaner) Generic

func (t *PVCCleaner) Generic(event.GenericEvent, workqueue.RateLimitingInterface)

Generic is called in response to an event of an unknown type or a synthetic event triggered as a cron or external trigger request - e.g. reconcile Autoscaling, or a Webhook.

func (*PVCCleaner) Update

func (t *PVCCleaner) Update(evt event.UpdateEvent, wq workqueue.RateLimitingInterface)

Update is called in response to an update event - e.g. Pod Updated.