watcher

Documentation

Index

• func CheckPods(ctx context.Context, kubeconfigPath, namespace string, opts metav1.ListOptions, ...) error
• func PendingPodsWatcher(ctx context.Context, namespace string, watchInterval time.Duration)

Functions

func CheckPods

func CheckPods(
	ctx context.Context,
	kubeconfigPath,
	namespace string,
	opts metav1.ListOptions,
	f func(context.Context, *corev1.Pod) error) error

CheckPods will firstly get a list of Pods by given list options. Then it will perform the action defined by the function parameter to deal with each Pod.

func PendingPodsWatcher

func PendingPodsWatcher(ctx context.Context, namespace string, watchInterval time.Duration)

PendingPodsWatcher watches the Pods in Pending phase and perform some actions.