e2e

README

E2E Tests

The following assumes some knowledge on running Knative tests. If this is your first time, see the Eventing Tests first before continuing. There you'll learn how to run the e2e suite, run specific tests, and create the required test images.

Debugging a Failed Test

Each e2e test will run in its own namespace, and the tests clean themselves up when they finish. To keep test namespaces around, simply comment out the env.Finish() line of the test you wish to focus on. Make sure you delete the namespaces when you're done.

Profiling RabbitMQ

RabbitMQ has a dashboard with lots of information available about the cluster that can be useful for debugging tests.

1. Get the credentials out of a secret on the Kubernetes cluster where the tests are running: kubectl -n <test namespace> get secrets rabbitmqc-default-user -o json | jq -r '.data["default_user.conf"]' | base64 -d

   Note: If you are running the SourceVHost test, you should use guest for both username and password.

2. Provided you are running your tests locally, you can port forward to get access to the RabbitMQ cluster: kubectl -n TEST-NAMESPACE port-forward rabbitmqc-server-0 8081:15672

3. Point your browser to http://localhost:8081 and log in with the credentials from step 1.

Documentation

Index

• func CleanUpTopologyOperatorVolumes(ctx context.Context, t feature.T)
• func CleanupSelfSignedCerts() *feature.Feature
• func PatchTopologyOperatorDeployment(ctx context.Context, t feature.T)
• func RabbitMQCluster() *feature.Feature
• func RabbitMQClusterConnectionSecretUri(ctx context.Context, t feature.T)
• func RabbitMQClusterConnectionSecretVhost(ctx context.Context, t feature.T)
• func RabbitMQClusterReady(ctx context.Context, t feature.T)
• func RabbitMQClusterVHost() *feature.Feature
• func RabbitMQClusterWithConnectionSecretUri() *feature.Feature
• func RabbitMQClusterWithTLS() *feature.Feature
• func RecorderFeature(options ...eventshub.EventsHubOption) *feature.Feature
• func SetupSelfSignedCerts() *feature.Feature
• func TopologyOperatorDeploymentReady(ctx context.Context, t feature.T)
• func TopologyOperatorDeploymentUpdated(ctx context.Context, t feature.T) (*appsv1.Deployment, error)

Functions

func CleanUpTopologyOperatorVolumes

func CleanUpTopologyOperatorVolumes(ctx context.Context, t feature.T)

func CleanupSelfSignedCerts

func CleanupSelfSignedCerts() *feature.Feature

func PatchTopologyOperatorDeployment

func PatchTopologyOperatorDeployment(ctx context.Context, t feature.T)

func RabbitMQCluster

func RabbitMQCluster() *feature.Feature

RabbitMQCluster creates a rabbitmq.com/rabbitmqclusters cluster that the Broker under test will use. This assumes that the RabbitMQ Operator has already been installed.

func RabbitMQClusterConnectionSecretUri

func RabbitMQClusterConnectionSecretUri(ctx context.Context, t feature.T)

func RabbitMQClusterConnectionSecretVhost

func RabbitMQClusterConnectionSecretVhost(ctx context.Context, t feature.T)

func RabbitMQClusterReady

func RabbitMQClusterReady(ctx context.Context, t feature.T)

func RabbitMQClusterVHost

func RabbitMQClusterVHost() *feature.Feature

func RabbitMQClusterWithConnectionSecretUri

func RabbitMQClusterWithConnectionSecretUri() *feature.Feature

func RabbitMQClusterWithTLS

func RabbitMQClusterWithTLS() *feature.Feature

func RecorderFeature

func RecorderFeature(options ...eventshub.EventsHubOption) *feature.Feature

func SetupSelfSignedCerts

func SetupSelfSignedCerts() *feature.Feature

func TopologyOperatorDeploymentReady

func TopologyOperatorDeploymentReady(ctx context.Context, t feature.T)

func TopologyOperatorDeploymentUpdated

func TopologyOperatorDeploymentUpdated(ctx context.Context, t feature.T) (*appsv1.Deployment, error)