Function RunInPod

shell/shell.go:31–67

RunInPod starts an interactive shell in a pod by creating and attaching to an ephemeral container.

(config Config, podNamespace, podName string)

// RunInPod starts an interactive shell in a pod by creating and attaching to an ephemeral container.
func RunInPod(config Config, podNamespace, podName string) error {
	ctx := context.Background()

	clientset, err := kubernetes.NewForConfig(config.RestConfig)
	if err != nil {
		return fmt.Errorf("error constructing kube clientset: %w", err)
	}

	pod, err := clientset.CoreV1().
		Pods(podNamespace).
		Get(ctx, podName, metav1.GetOptions{})
	if err != nil {
		return fmt.Errorf("error retrieving pod %s from namespace %s: %w", podName, podNamespace, err)
	}

	err = validateOperatingSystemSupportedForNode(ctx, clientset, pod.Spec.NodeName)
	if err != nil {
		return fmt.Errorf("error validating operating system for node %s: %w", pod.Spec.NodeName, err)
	}

	fmt.Printf("Starting ephemeral container in pod %s/%s\n", podNamespace, podName)
	ephemeralContainer := ephemeralContainerForPodDebug(config)
	pod.Spec.EphemeralContainers = append(pod.Spec.EphemeralContainers, ephemeralContainer)

	_, err = clientset.CoreV1().
		Pods(podNamespace).
		UpdateEphemeralContainers(ctx, podName, pod, metav1.UpdateOptions{})
	if err != nil {
		return fmt.Errorf("error updating ephemeral containers: %w", err)
	}

	if err := waitForContainerRunning(ctx, config.Timeout, clientset, podNamespace, podName, ephemeralContainer.Name); err != nil {
		return fmt.Errorf("error waiting for containers running: %w", err)
	}

	return attachToShell(config.RestConfig, podNamespace, podName, ephemeralContainer.Name, pod)
}

// RunInNode starts an interactive shell on a node by creating a HostNetwork pod and attaching to it.
func RunInNode(config Config, nodeName, debugPodNamespace string) error {