k8s

Documentation

Index

• func ExecPod(ctx context.Context, clusterID string, pod *corev1.Pod) error
• func FindLatestOrLastFailedPod(pods []corev1.Pod) (latest *corev1.Pod, lastFailed *corev1.Pod)
• func ListPodsForJob(ctx context.Context, clusterID, ns, name string) ([]corev1.Pod, error)
• func NewClient(env *runtime.Env, clusterID string) (kubernetes.Interface, error)
• func PortForward(ctx context.Context, clusterID string, pod *corev1.Pod, ...) error
• func StreamPodLogs(ctx context.Context, clusterID string, pod *corev1.Pod, follow bool) error

Functions

func ExecPod

func ExecPod(ctx context.Context, clusterID string, pod *corev1.Pod) error

ExecPod exects into a pod.

func FindLatestOrLastFailedPod

func FindLatestOrLastFailedPod(pods []corev1.Pod) (latest *corev1.Pod, lastFailed *corev1.Pod)

FindLatestOrLastFailedPod finds the latest pod and the last failed pod from the given list of pods.

func ListPodsForJob

func ListPodsForJob(ctx context.Context, clusterID, ns, name string) ([]corev1.Pod, error)

ListPodsForJob lists all pods for the given job.

func NewClient

func NewClient(env *runtime.Env, clusterID string) (kubernetes.Interface, error)

NewClient creates a new Kubernetes client.

func PortForward

func PortForward(ctx context.Context, clusterID string, pod *corev1.Pod, localPort, remotePort int) error

PortForward establishes a port-forwarding session to a pod.

This first attempts tunneling (websocket) dialer, then fallback to SPDY dialer. Please note that the websocket works only with k8s 1.30 with the "PortForwardWebsockets" feature gate enabled.

func StreamPodLogs

func StreamPodLogs(ctx context.Context, clusterID string, pod *corev1.Pod, follow bool) error

StreamPodLogs streams logs from the given pod to stdout.