utils

Documentation

Index

• Variables
• func BeginOperateLifecycle(client client.Client, adapter podopslifecycle.LifecycleAdapter, ...) (bool, 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)
• func SetOpsStatusError(candidate *opscore.OpsCandidate, reason string, message string)

Variables

var (
	StatusUpToDateExpectation = expectations.NewResourceVersionExpectation()
)

Functions

func BeginOperateLifecycle

func BeginOperateLifecycle(client client.Client, adapter podopslifecycle.LifecycleAdapter, pod *corev1.Pod) (bool, 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)

func SetOpsStatusError

func SetOpsStatusError(candidate *opscore.OpsCandidate, reason string, message string)