func()

in contrib/utils/kubectl_cmd.go [56:81]

• 22 lines of code
• 6 McCabe index (conditional complexity)

func (kr *KubectlRunner) Wait(ctx context.Context, timeout time.Duration, condition, waitTimeout, target string) error {
	if condition == "" {
		return fmt.Errorf("condition is required")
	}

	if target == "" {
		return fmt.Errorf("target is required")
	}

	args := []string{}
	if kr.kubeCfgPath != "" {
		args = append(args, "--kubeconfig", kr.kubeCfgPath)
	}
	if kr.namespace != "" {
		args = append(args, "-n", kr.namespace)
	}

	args = append(args, "wait", "--for="+condition)
	if waitTimeout != "" {
		args = append(args, "--timeout="+waitTimeout)
	}
	args = append(args, target)

	_, err := runCommand(ctx, timeout, "kubectl", args)
	return err
}