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)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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 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 ¶
BuildCRPVCLabels generate CR subresource pvc labels
func CheckOwnerRefExists ¶
func CheckOwnerRefExists(owner metav1.Object, refs []metav1.OwnerReference) (refExists bool)
CheckOwnerRefExists check onwer reference exists
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.