Function QueryInInstancePodWithTimeout

tests/utils/exec/exec.go:118–134

QueryInInstancePodWithTimeout executes a query in an instance pod, by connecting to the pod and the postgres container, and using a local connection with the postgres user

(
	ctx context.Context,
	crudClient client.Client,
	kubeInterface kubernetes.Interface,
	restConfig *rest.Config,
	podLocator PodLocator,
	dbname DatabaseName,
	query string,
	timeout time.Duration,
)

// QueryInInstancePodWithTimeout executes a query in an instance pod, by connecting to the pod
// and the postgres container, and using a local connection with the postgres user
func QueryInInstancePodWithTimeout(
	ctx context.Context,
	crudClient client.Client,
	kubeInterface kubernetes.Interface,
	restConfig *rest.Config,
	podLocator PodLocator,
	dbname DatabaseName,
	query string,
	timeout time.Duration,
) (string, string, error) {
	return CommandInInstancePod(
		ctx, crudClient, kubeInterface, restConfig,
		PodLocator{
			Namespace: podLocator.Namespace,
			PodName:   podLocator.PodName,
		}, &timeout, "psql", "-U", "postgres", string(dbname), "-tAc", query)
}

// EventuallyExecQueryInInstancePod wraps QueryInInstancePod with an Eventually clause
func EventuallyExecQueryInInstancePod(