Function waitForContainerRunning

shell/attach.go:47–80

(ctx context.Context, timeout time.Duration, clientset *kubernetes.Clientset, namespace, podName, containerName string)

}

func waitForContainerRunning(ctx context.Context, timeout time.Duration, clientset *kubernetes.Clientset, namespace, podName, containerName string) error {
	ctx, cancel := context.WithTimeout(ctx, timeout)
	defer cancel()
	for {
		pod, err := clientset.CoreV1().
			Pods(namespace).
			Get(ctx, podName, metav1.GetOptions{})
		if err != nil {
			if errors.Is(err, context.DeadlineExceeded) {
				return waitTimeoutError(err, timeout, containerName)
			}
			return fmt.Errorf("error retrieving pod %s in namespace %s: %w", podName, namespace, err)
		}

		for i := range pod.Status.ContainerStatuses {
			status := pod.Status.ContainerStatuses[i]
			if status.Name == containerName && status.State.Running != nil {
				return nil
			}
		}
		for i := range pod.Status.EphemeralContainerStatuses {
			status := pod.Status.EphemeralContainerStatuses[i]
			if status.Name == containerName && status.State.Running != nil {
				return nil
			}
		}

		select {
		case <-ctx.Done():
			return waitTimeoutError(context.DeadlineExceeded, timeout, containerName)
		case <-time.After(1 * time.Second):
		}
	}
}

func waitTimeoutError(err error, timeout time.Duration, containerName string) error {
	return fmt.Errorf("timed out after %s waiting for container %s to start. The timeout can be increased by setting --timeout. Err: %w", timeout, containerName, err)