k8s

Documentation

Index

• func ExecPod(ctx context.Context, clusterID string, pod *corev1.Pod) error
• func NewClient(env *runtime.Env, clusterID string) (kubernetes.Interface, error)
• func PortForward(ctx context.Context, clusterID string, pod *corev1.Pod, ...) error

Functions

func ExecPod

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

ExecPod exects into a pod.

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.