testhelpers

func CreateSimpleInstance ¶

func CreateSimpleInstance(k8sEnv K8sOperatorEnvironment, instanceName string, version string, edition string)

CreateSimpleInstance creates a basic v1alpha1.Instance object named 'instanceName'. 'version' and 'edition' should match rules of TestImageForVersion(). Depends on the Ginkgo asserts.

func CreateSimplePDB ¶

func CreateSimplePDB(k8sEnv K8sOperatorEnvironment, instanceName string)

CreateSimplePDB creates a simple PDB 'pdb1' inside 'instanceName' Instance. Depends on the Ginkgo asserts.

func CreateSimplePdbWithDbObj ¶

func CreateSimplePdbWithDbObj(k8sEnv K8sOperatorEnvironment, database *v1alpha1.Database)

CreateSimplePdbWithDbObj creates simple PDB by given database object.

func DeployOperator ¶

func DeployOperator(ctx context.Context, k8sClient client.Client, namespace string) (func() error, error)

DeployOperator deploys an operator and returns a cleanup function to delete all cluster level objects created outside of the namespace.

func GCloudServiceAccount ¶

func GCloudServiceAccount() string

GCloudServiceAccount returns the GCloud service account name.

func InsertSimpleData ¶

func InsertSimpleData(k8sEnv K8sOperatorEnvironment)

InsertSimpleData creates 'test_table' in pdb1 and inserts a test row.

func K8sCreateAndGet ¶

func K8sCreateAndGet(k8sClient client.Client, ctx context.Context, objKey client.ObjectKey, obj runtime.Object, createdObj runtime.Object)

K8sCreateAndGet calls k8s Create() with retry and then wait for the object to be created. Updates 'createdObj' with the created object.

func K8sCreateWithRetry ¶

func K8sCreateWithRetry(k8sClient client.Client, ctx context.Context, obj runtime.Object)

K8sCreateWithRetry calls k8s Create() with retry as k8s might require this in some cases (e.g. conflicts).

func K8sDeleteWithRetry ¶

func K8sDeleteWithRetry(k8sClient client.Client, ctx context.Context, obj runtime.Object)

K8sDeleteWithRetry calls k8s Delete() with retry as k8s might require this in some cases (e.g. conflicts).

func K8sExec ¶

func K8sExec(pod string, ns string, container string, cmd string) (string, error)

K8sExec execs a command in a pod and returns a string result. Depends on the Ginkgo asserts. kubectl exec <pod> <cmd> -n <ns> -c <container>

func K8sExecuteSql ¶

func K8sExecuteSql(pod string, ns string, sql string) (string, error)

K8sExecuteSql executes multiple sql statements in an Oracle pod e.g. sql := `alter session set container=pdb1; create table test_table (name varchar(100)); insert into test_table values ('Hello World'); commit;` out, err = testhelpers.K8sExecuteSql("mydb-sts-0", "db", sql) Depends on the Ginkgo asserts. Please escape any bash special characters.

func K8sExecuteSqlOrFail ¶

func K8sExecuteSqlOrFail(pod, ns, sql string) string

K8sExecuteSqlOrFail is the same as K8sExecuteSql but raises a ginkgo assert on failure.

func K8sGetAndUpdateWithRetry ¶

func K8sGetAndUpdateWithRetry(k8sClient client.Client,
	ctx context.Context,
	objKey client.ObjectKey,
	emptyObj runtime.Object,
	modifyObjectFunc func(*runtime.Object))

Simple helper to make the Get-Modify-Update-Retry cycle easier Get a fresh version of the object into 'emptyObj' using 'objKey' Apply user-supplied modifyObjectFunc() which should modify the 'emptyObj' Try to update 'emptyObj' in k8s, retry if needed

func K8sGetWithRetry ¶

func K8sGetWithRetry(k8sClient client.Client, ctx context.Context, instKey client.ObjectKey, obj runtime.Object)

K8sGetWithRetry calls k8s Get() with retry as k8s might require this in some cases (e.g. conflicts).

func K8sVerifyUserConnectivity ¶

func K8sVerifyUserConnectivity(pod, ns, pdb string, userCred map[string]string)

K8sVerifyUserConnectivity verified user connectivity on "oracledb" container. Or raise ginkgo assertion on failure. 5 retried in 30 second for each user is performed to workaround potential password sync latency between Config Server and Oracle DB.

func PrintClusterObjects ¶

func PrintClusterObjects()

Print cluster objects - events, pods, pvcs for all namespaces in the cluster

func PrintENV ¶

func PrintENV()

Print ENV variables

func PrintEvents ¶

func PrintEvents()

PrintEvents for all namespaces in the cluster.

func PrintLogs ¶

func PrintLogs(namespace string, env envtest.Environment, dumpLogsFor []string, instances []string)

Print logs from requested containers

func PrintPVCs ¶

func PrintPVCs()

Print PVCs for all namespaces in the cluster

func PrintPods ¶

func PrintPods()

Print pods for all namespaces in the cluster

func PrintSVCs ¶

func PrintSVCs()

Print svcs for all namespaces in the cluster

func RandName ¶

func RandName(base string) string

RandName generates a name suitable for use as a namespace with a given prefix.

func RunReconcilerTestSuite ¶

func RunReconcilerTestSuite(t *testing.T, k8sClient *client.Client, k8sManager *ctrl.Manager, description string, controllers func() []Reconciler)

RunReconcilerTestSuite runs all specs in the current package against a specialized testing environment. Before running the suite, this function configures the test environment by taking the following actions:

• Starting a control plane consisting of an etcd process and a Kubernetes API server process.
• Installing CRDs into the control plane
• Starting an in-process manager in a dedicated goroutine with the given reconcilers installed in it.

These components will be torn down after the suite runs.

func SetupServiceAccountBindingBetweenGcpAndK8s ¶

func SetupServiceAccountBindingBetweenGcpAndK8s(k8sEnv K8sOperatorEnvironment)

SetupServiceAccountBindingBetweenGcpAndK8s creates IAM policy binding between k8s service account <projectId>.svc.id.goog[<NAMESPACE>/default] and google service account.

func TestImageForVersion ¶

func TestImageForVersion(version string, edition string, extra string) string

TestImageForVersion returns service image for integration tests. Image paths are predefined in the env variables TEST_IMAGE_ORACLE_*.

func VerifySimpleData ¶

func VerifySimpleData(k8sEnv K8sOperatorEnvironment)

VerifySimpleData checks that the test row in 'pdb1' exists.

func WaitForInstanceConditionState ¶

func WaitForInstanceConditionState(k8sEnv K8sOperatorEnvironment, key client.ObjectKey, condition string, targetStatus metav1.ConditionStatus, targetReason string, timeout time.Duration)

WaitForInstanceConditionState waits until the Instance condition object status = targetStatus and reason = targetReason. Depends on the Ginkgo asserts.

func WaitForObjectConditionState ¶

func WaitForObjectConditionState(k8sEnv K8sOperatorEnvironment,
	key client.ObjectKey,
	emptyObj runtime.Object,
	condition string,
	targetStatus metav1.ConditionStatus,
	targetReason string,
	timeout time.Duration)

WaitForObjectConditionState waits until the k8s object condition object status = targetStatus and reason = targetReason. Objects supported: v1alpha1. {Instance, Import, Export} Depends on the Ginkgo asserts.