k8s_utils

Documentation

Index

• func IsKubernetesResourceAlreadyExistError(err error) bool
• func IsKubernetesResourceNotExist(err error) bool
• func RetryCreateAndWaitPod(ctx context.Context, cli client.Client, pod *corev1.Pod, ...) (*corev1.Pod, error)
• func RetryPushPod2List(_ context.Context, sl *list.SafeListLimited, task *v1alpha1.OrderStep, ...) error
• func TaskAddNormalEvent(recorder record.EventRecorder, orderTaskName string)
• func TaskDeleteEvent(recorder record.EventRecorder, orderTaskName string)
• func TaskUpgradeEvent(recorder record.EventRecorder, orderTaskName string)

Functions

func IsKubernetesResourceAlreadyExistError

func IsKubernetesResourceAlreadyExistError(err error) bool

func IsKubernetesResourceNotExist

func IsKubernetesResourceNotExist(err error) bool

func RetryCreateAndWaitPod

func RetryCreateAndWaitPod(ctx context.Context, cli client.Client, pod *corev1.Pod, interval time.Duration, maxRetries int) (*corev1.Pod, error)

func RetryPushPod2List

func RetryPushPod2List(_ context.Context, sl *list.SafeListLimited, task *v1alpha1.OrderStep, interval time.Duration, maxRetries int) error

func TaskAddNormalEvent

func TaskAddNormalEvent(recorder record.EventRecorder, orderTaskName string)

func TaskDeleteEvent

func TaskDeleteEvent(recorder record.EventRecorder, orderTaskName string)

func TaskUpgradeEvent

func TaskUpgradeEvent(recorder record.EventRecorder, orderTaskName string)