integration

README

Integration Tests

This folder contains the integration tests and their utilities of the project.

These tests here are primarily used to test the Addon Operator itself and it's interaction with Kubernetes/OpenShift and OLM.

Previously these tests where named e2e-tests, but we choose to rename them, because the real end to end tests are done with osde2e and OCM.

Documentation

Overview

Package integration contains the Addon Operator integration tests.

Index

• Constants
• Variables
• func ExecCommandInPod(namespace string, pod string, container string, command []string) (string, string, error)
• func InitOCMClient() error
• func PrintPodStatusAndLogs(namespace string) error
• func RunAPIServerProxy(closeCh <-chan struct{}) error
• func WaitForFreshAddonCondition(t *testing.T, timeout time.Duration, a *addonsv1alpha1.Addon, ...) error
• func WaitForObject(ctx context.Context, t *testing.T, timeout time.Duration, object client.Object, ...) error
• func WaitForObjectWithInterval(ctx context.Context, t *testing.T, interval time.Duration, ...) error
• func WaitToBeGone(ctx context.Context, t *testing.T, timeout time.Duration, object client.Object) error

Constants

const (
	OCMAPIEndpoint = "http://api-mock.api-mock.svc.cluster.local"
)

Variables

var (
	// Client pointing to the e2e test cluster.
	Client    client.Client
	Config    *rest.Config
	Scheme    = runtime.NewScheme()
	Cv        *configv1.ClusterVersion
	OCMClient *ocm.Client
	// Namespace that the Addon Operator is running in.
	// Needs to be auto-discovered, because OpenShift CI is installing the Operator in a non deterministic namespace.
	AddonOperatorNamespace string

	// Typed K8s Clients
	CoreV1Client corev1client.CoreV1Interface
)

Functions

func ExecCommandInPod

func ExecCommandInPod(namespace string, pod string, container string, command []string) (string, string, error)

func InitOCMClient

func InitOCMClient() error

func PrintPodStatusAndLogs

func PrintPodStatusAndLogs(namespace string) error

Prints the phase of a pod together with the logs of every container.

func RunAPIServerProxy

func RunAPIServerProxy(closeCh <-chan struct{}) error

Runs a local apiserver proxy on 127.0.0.1:8001 similar to `kubectl proxy`.

func WaitForFreshAddonCondition

func WaitForFreshAddonCondition(
	t *testing.T, timeout time.Duration,
	a *addonsv1alpha1.Addon, conditionType string, conditionStatus metav1.ConditionStatus,
) error

Wait for an up-to-date condition value on an addon. A condition is considered up-to-date when it's .ObservedGeneration matches the generation of it's addon object.

func WaitForObject

func WaitForObject(
	ctx context.Context,
	t *testing.T, timeout time.Duration,
	object client.Object, reason string,
	checkFn func(obj client.Object) (done bool, err error),
) error

Wait that something happens with an object.

func WaitForObjectWithInterval

func WaitForObjectWithInterval(
	ctx context.Context,
	t *testing.T, interval time.Duration, timeout time.Duration,
	object client.Object, reason string,
	checkFn func(obj client.Object) (done bool, err error),
) error

func WaitToBeGone

func WaitToBeGone(ctx context.Context, t *testing.T, timeout time.Duration, object client.Object) error

WaitToBeGone blocks until the given object is gone from the kubernetes API server.