Function EventuallyExecQueryInInstancePod

tests/utils/exec/exec.go:137–159

EventuallyExecQueryInInstancePod wraps QueryInInstancePod with an Eventually clause

(
	ctx context.Context,
	crudClient client.Client,
	kubeInterface kubernetes.Interface,
	restConfig *rest.Config,
	podLocator PodLocator,
	dbname DatabaseName,
	query string,
	retryTimeout int,
	pollingTime int,
)

// EventuallyExecQueryInInstancePod wraps QueryInInstancePod with an Eventually clause
func EventuallyExecQueryInInstancePod(
	ctx context.Context,
	crudClient client.Client,
	kubeInterface kubernetes.Interface,
	restConfig *rest.Config,
	podLocator PodLocator,
	dbname DatabaseName,
	query string,
	retryTimeout int,
	pollingTime int,
) (string, string, error) {
	var stdOut, stdErr string
	var err error

	Eventually(func() error {
		stdOut, stdErr, err = QueryInInstancePod(
			ctx, crudClient, kubeInterface, restConfig,
			podLocator, dbname, query)
		return err
	}, retryTimeout, pollingTime).Should(Succeed())

	return stdOut, stdErr, err
}

// Command wraps the utils.ExecCommand pre-setting values constant during
// tests