Function ExecCommand

pkg/utils/exec.go:97–174

ExecCommand executes a command inside the pod, automatically retrying transient errors like proxy failures or network issues.

(
	ctx context.Context,
	client kubernetes.Interface,
	config *rest.Config,
	pod corev1.Pod,
	containerName string,
	timeout *time.Duration,
	command ...string,
)

// ExecCommand executes a command inside the pod, automatically retrying
// transient errors like proxy failures or network issues.
func ExecCommand(
	ctx context.Context,
	client kubernetes.Interface,
	config *rest.Config,
	pod corev1.Pod,
	containerName string,
	timeout *time.Duration,
	command ...string,
) (string, string, error) {
	contextLogger := log.FromContext(ctx).WithValues(
		"pod", pod.Name,
		"namespace", pod.Namespace,
		"container", containerName,
	)

	targetContainer := -1
	for i, cr := range pod.Spec.Containers {
		if cr.Name == containerName {
			targetContainer = i
			break
		}
	}

	if targetContainer < 0 {
		return "", "", ErrorContainerNotFound
	}

	execCtx := ctx
	var cancelFunc context.CancelFunc
	if timeout != nil {
		execCtx, cancelFunc = context.WithTimeout(ctx, *timeout)
		defer cancelFunc()
	}

	var stdout, stderr string
	var execErr error

	_ = retry.New(
		retry.Attempts(execRetryAttempts),
		retry.Delay(execRetryDelay),
		retry.DelayType(retry.BackOffDelay),
		retry.Context(execCtx),
		retry.LastErrorOnly(true),
		retry.OnRetry(func(n uint, err error) {
			contextLogger.Info("Retrying kubectl exec",
				"attempt", n+1,
				"error", err.Error(),
			)
		}),
	).Do(
		func() error {
			stdout, stderr, execErr = execCommandOnce(
				execCtx, client, config, pod,
				targetContainer, timeout, command...,
			)

			// Don't retry if context was cancelled or timed out
			if execCtx.Err() != nil {