pods

Documentation

Index

• Constants
• func DumpEventsForPod(events []corev1.Event, podNamespace, podName string) string
• func ExpectPodToBeRunning(cli kubernetes.Interface, podNamespace, podName string, timeout time.Duration) *corev1.Pod
• func GetByDaemonSet(cli client.Client, ctx context.Context, daemonset appsv1.DaemonSet) ([]corev1.Pod, error)
• func GetByDeployment(cli client.Client, ctx context.Context, deployment appsv1.Deployment) ([]corev1.Pod, error)
• func GetByRegex(cs client.Client, reg string) ([]*corev1.Pod, error)
• func GetEventsForPod(k8sCli kubernetes.Interface, ctx context.Context, podNamespace, podName string) ([]corev1.Event, error)
• func GetLogsForPod(k8sCli kubernetes.Interface, podNamespace, podName, containerName string) (string, error)
• func GuaranteedSleeperPod(namespace, schedulerName string) *corev1.Pod
• func LogEventsForPod(k8sCli kubernetes.Interface, ctx context.Context, podNamespace, podName string) error
• func WaitForPodToBeRunning(ctx context.Context, cli kubernetes.Interface, podNamespace, podName string, ...) (*corev1.Pod, error)
• func WaitPodsToBeRunningByRegex(pattern string)

Constants

const (
	CentosImage = "quay.io/centos/centos:8"
)

Functions

func DumpEventsForPod

func DumpEventsForPod(events []corev1.Event, podNamespace, podName string) string

func ExpectPodToBeRunning

func ExpectPodToBeRunning(cli kubernetes.Interface, podNamespace, podName string, timeout time.Duration) *corev1.Pod

func GetByDaemonSet

func GetByDaemonSet(cli client.Client, ctx context.Context, daemonset appsv1.DaemonSet) ([]corev1.Pod, error)

func GetByDeployment

func GetByDeployment(cli client.Client, ctx context.Context, deployment appsv1.Deployment) ([]corev1.Pod, error)

func GetByRegex

func GetByRegex(cs client.Client, reg string) ([]*corev1.Pod, error)

func GetEventsForPod

func GetEventsForPod(k8sCli kubernetes.Interface, ctx context.Context, podNamespace, podName string) ([]corev1.Event, error)

func GetLogsForPod

func GetLogsForPod(k8sCli kubernetes.Interface, podNamespace, podName, containerName string) (string, error)

func GuaranteedSleeperPod

func GuaranteedSleeperPod(namespace, schedulerName string) *corev1.Pod

func LogEventsForPod

func LogEventsForPod(k8sCli kubernetes.Interface, ctx context.Context, podNamespace, podName string) error

func WaitForPodToBeRunning

func WaitForPodToBeRunning(ctx context.Context, cli kubernetes.Interface, podNamespace, podName string, timeout time.Duration) (*corev1.Pod, error)

func WaitPodsToBeRunningByRegex

func WaitPodsToBeRunningByRegex(pattern string)