podopslifecycle

Documentation

Index

• func Add(mgr manager.Manager) error
• func AddToMgr(mgr manager.Manager, r reconcile.Reconciler) error
• func IsLifecycleOnPod(lifecycleId string, pod *corev1.Pod) (bool, error)
• func NumOfLifecycleOnPod(pod *corev1.Pod) (int, error)
• func PodIDAndTypesMap(pod *corev1.Pod) (map[string]map[string]string, map[string]int, error)
• type NeedOpsLifecycle
• type PodPredicate
  • func (pp *PodPredicate) Create(evt event.CreateEvent) bool
  • func (pp *PodPredicate) Delete(evt event.DeleteEvent) bool
  • func (pp *PodPredicate) Generic(evt event.GenericEvent) bool
  • func (pp *PodPredicate) Update(evt event.UpdateEvent) bool
• type ReconcilePodOpsLifecycle
  • func NewReconciler(mgr manager.Manager) *ReconcilePodOpsLifecycle
  • func (r *ReconcilePodOpsLifecycle) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)

Functions

func Add

func Add(mgr manager.Manager) error

func AddToMgr

func AddToMgr(mgr manager.Manager, r reconcile.Reconciler) error

func IsLifecycleOnPod

func IsLifecycleOnPod(lifecycleId string, pod *corev1.Pod) (bool, error)

IsLifecycleOnPod returns true if the lifecycle with lifecycleId exist on pod, otherwise returns false

func NumOfLifecycleOnPod

func NumOfLifecycleOnPod(pod *corev1.Pod) (int, error)

NumOfLifecycleOnPod returns the nums of lifecycles on pod

func PodIDAndTypesMap

func PodIDAndTypesMap(pod *corev1.Pod) (map[string]map[string]string, map[string]int, error)

PodIDAndTypesMap returns a map of pod id to labels map and a map of operation type to number of pods.

Types

type NeedOpsLifecycle

type NeedOpsLifecycle func(oldPod, newPod *corev1.Pod) bool

type PodPredicate

type PodPredicate struct {
	NeedOpsLifecycle // Check if pod need be reconciled
}

func (*PodPredicate) Create

func (pp *PodPredicate) Create(evt event.CreateEvent) bool

func (*PodPredicate) Delete

func (pp *PodPredicate) Delete(evt event.DeleteEvent) bool

func (*PodPredicate) Generic

func (pp *PodPredicate) Generic(evt event.GenericEvent) bool

func (*PodPredicate) Update

func (pp *PodPredicate) Update(evt event.UpdateEvent) bool

type ReconcilePodOpsLifecycle

type ReconcilePodOpsLifecycle struct {
	*mixin.ReconcilerMixin
	// contains filtered or unexported fields
}

func NewReconciler

func NewReconciler(mgr manager.Manager) *ReconcilePodOpsLifecycle

func (*ReconcilePodOpsLifecycle) Reconcile

func (r *ReconcilePodOpsLifecycle) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)