utils

Documentation

Index

• Variables
• func BeginOperateLifecycle(client client.Client, adapter podopslifecycle.LifecycleAdapter, ...) error
• func CancelOpsLifecycle(ctx context.Context, client client.Client, ...) error
• func EnqueueOperationJobFromPod(c client.Client, pod *corev1.Pod, q *workqueue.RateLimitingInterface, ...)
• func FinishOperateLifecycle(client client.Client, adapter podopslifecycle.LifecycleAdapter, ...) error
• func IsJobFinished(instance *appsv1alpha1.OperationJob) bool
• func MapOpsStatusByPod(instance *appsv1alpha1.OperationJob) map[string]*appsv1alpha1.OpsStatus
• func MarkOperationJobFailed(instance *appsv1alpha1.OperationJob)

Variables

var (
	StatusUpToDateExpectation = expectations.NewResourceVersionExpectation()
)

Functions

func BeginOperateLifecycle

func BeginOperateLifecycle(client client.Client, adapter podopslifecycle.LifecycleAdapter, pod *corev1.Pod) error

func CancelOpsLifecycle

func CancelOpsLifecycle(ctx context.Context, client client.Client, adapter podopslifecycle.LifecycleAdapter, pod *corev1.Pod) error

func EnqueueOperationJobFromPod

func EnqueueOperationJobFromPod(c client.Client, pod *corev1.Pod, q *workqueue.RateLimitingInterface, fn func(client.Client, *corev1.Pod) (sets.String, bool))

func FinishOperateLifecycle

func FinishOperateLifecycle(client client.Client, adapter podopslifecycle.LifecycleAdapter, pod *corev1.Pod) error

func IsJobFinished

func IsJobFinished(instance *appsv1alpha1.OperationJob) bool

func MapOpsStatusByPod

func MapOpsStatusByPod(instance *appsv1alpha1.OperationJob) map[string]*appsv1alpha1.OpsStatus

func MarkOperationJobFailed

func MarkOperationJobFailed(instance *appsv1alpha1.OperationJob)