pods

Documentation

Index

• Constants
• func CheckPODSchedulingFailed(c client.Client, pod *corev1.Pod) (bool, error)
• func DumpResourceRequirements(pod *corev1.Pod) string
• func ExecCommandOnPod(c *kubernetes.Clientset, pod *corev1.Pod, containerName string, ...) ([]byte, error)
• func GetContainerIDByName(pod *corev1.Pod, containerName string) (string, error)
• func GetLogs(c *kubernetes.Clientset, pod *corev1.Pod) (string, error)
• func GetPodsOnNode(ctx context.Context, nodeName string) ([]corev1.Pod, error)
• func GetTestPod() *corev1.Pod
• func WaitForCondition(ctx context.Context, podKey client.ObjectKey, ...) (*corev1.Pod, error)
• func WaitForDeletion(ctx context.Context, pod *corev1.Pod, timeout time.Duration) error
• func WaitForPhase(ctx context.Context, podKey client.ObjectKey, phase corev1.PodPhase, ...) (*corev1.Pod, error)
• func WaitForPodOutput(ctx context.Context, c *kubernetes.Clientset, pod *corev1.Pod, ...) ([]byte, error)
• func WaitForPredicate(ctx context.Context, podKey client.ObjectKey, timeout time.Duration, ...) (*corev1.Pod, error)

Constants

const DefaultDeletionTimeout = 120

DefaultDeletionTimeout contains the default pod deletion timeout in seconds

Functions

func CheckPODSchedulingFailed

func CheckPODSchedulingFailed(c client.Client, pod *corev1.Pod) (bool, error)

func DumpResourceRequirements

func DumpResourceRequirements(pod *corev1.Pod) string

func ExecCommandOnPod

func ExecCommandOnPod(c *kubernetes.Clientset, pod *corev1.Pod, containerName string, command []string) ([]byte, error)

ExecCommandOnPod runs command in the pod and returns buffer output

func GetContainerIDByName

func GetContainerIDByName(pod *corev1.Pod, containerName string) (string, error)

GetContainerIDByName returns container ID under the pod by the container name

func GetLogs

func GetLogs(c *kubernetes.Clientset, pod *corev1.Pod) (string, error)

GetLogs returns logs of the specified pod

func GetPodsOnNode

func GetPodsOnNode(ctx context.Context, nodeName string) ([]corev1.Pod, error)

func GetTestPod

func GetTestPod() *corev1.Pod

GetTestPod returns pod with the busybox image

func WaitForCondition

func WaitForCondition(ctx context.Context, podKey client.ObjectKey, conditionType corev1.PodConditionType, conditionStatus corev1.ConditionStatus, timeout time.Duration) (*corev1.Pod, error)

WaitForCondition waits until the pod will have specified condition type with the expected status

func WaitForDeletion

func WaitForDeletion(ctx context.Context, pod *corev1.Pod, timeout time.Duration) error

WaitForDeletion waits until the pod will be removed from the cluster

func WaitForPhase

func WaitForPhase(ctx context.Context, podKey client.ObjectKey, phase corev1.PodPhase, timeout time.Duration) (*corev1.Pod, error)

WaitForPhase waits until the pod will have specified phase

func WaitForPodOutput

func WaitForPodOutput(ctx context.Context, c *kubernetes.Clientset, pod *corev1.Pod, command []string) ([]byte, error)

func WaitForPredicate

func WaitForPredicate(ctx context.Context, podKey client.ObjectKey, timeout time.Duration, pred func(pod *corev1.Pod) (bool, error)) (*corev1.Pod, error)

WaitForPredicate waits until the given predicate against the pod returns true or error.