e2e

README

End to end tests

• Running e2e tests

Adding end to end tests

Knative Eventing e2e tests test the end to end functionality of the Knative Eventing API to verify the behavior of this specific implementation.

Requirements

The e2e tests are used to test whether the flow of Knative Eventing is performing as designed from start to finish.

The e2e tests MUST:

1. Provide frequent output describing what actions they are undertaking, especially before performing long running operations.
2. Follow Golang best practices.

Documentation

Index

• Constants
• func CreateBroker(clients *test.Clients, broker *v1alpha1.Broker, logf logging.FormatLogger, ...) error
• func CreateChannel(clients *test.Clients, channel *v1alpha1.Channel, _ logging.FormatLogger, ...) error
• func CreateClusterRoleBinding(clients *test.Clients, crb *rbacv1.ClusterRoleBinding, _ logging.FormatLogger, ...) error
• func CreatePod(clients *test.Clients, pod *corev1.Pod, _ logging.FormatLogger, ...) error
• func CreateRouteAndConfig(clients *test.Clients, logf logging.FormatLogger, cleaner *test.Cleaner, ...) error
• func CreateService(clients *test.Clients, svc *corev1.Service, _ logging.FormatLogger, ...) error
• func CreateServiceAccount(clients *test.Clients, sa *corev1.ServiceAccount, _ logging.FormatLogger, ...) error
• func CreateServiceAccountAndBinding(clients *test.Clients, name string, logf logging.FormatLogger, ...) error
• func CreateSubscription(clients *test.Clients, sub *v1alpha1.Subscription, _ logging.FormatLogger, ...) error
• func CreateTrigger(clients *test.Clients, trigger *v1alpha1.Trigger, logf logging.FormatLogger, ...) error
• func FindAnyLogContents(clients *test.Clients, logf logging.FormatLogger, podName string, ...) (bool, error)
• func LabelNamespace(clients *test.Clients, logf logging.FormatLogger, labels map[string]string) error
• func NamespaceExists(t *testing.T, clients *test.Clients, logf logging.FormatLogger) (string, func())
• func Setup(t *testing.T, logf logging.FormatLogger) (*test.Clients, *test.Cleaner)
• func TearDown(clients *test.Clients, cleaner *test.Cleaner, _ logging.FormatLogger)
• func WaitForAllTriggersReady(clients *test.Clients, logf logging.FormatLogger, namespace string) error
• func WaitForBrokerReady(clients *test.Clients, broker *v1alpha1.Broker) error
• func WaitForLogContents(clients *test.Clients, logf logging.FormatLogger, podName string, ...) error
• func WithBrokerReady(clients *test.Clients, broker *v1alpha1.Broker, logf logging.FormatLogger, ...) error
• func WithChannelAndSubscriptionReady(clients *test.Clients, channel *v1alpha1.Channel, sub *v1alpha1.Subscription, ...) error
• func WithRouteReady(clients *test.Clients, logf logging.FormatLogger, cleaner *test.Cleaner, ...) error
• func WithTriggerReady(clients *test.Clients, trigger *v1alpha1.Trigger, logf logging.FormatLogger, ...) error

Constants

const (
	DefaultTestNamespace = "e2etest-knative-eventing"
)

Functions

func CreateBroker

func CreateBroker(clients *test.Clients, broker *v1alpha1.Broker, logf logging.FormatLogger, cleaner *test.Cleaner) error

CreateBroker will create a Broker.

func CreateChannel

func CreateChannel(clients *test.Clients, channel *v1alpha1.Channel, _ logging.FormatLogger, cleaner *test.Cleaner) error

CreateChannel will create a Channel

func CreateClusterRoleBinding

func CreateClusterRoleBinding(clients *test.Clients, crb *rbacv1.ClusterRoleBinding, _ logging.FormatLogger, cleaner *test.Cleaner) error

CreateClusterRoleBinding will create a service account binding

func CreatePod

func CreatePod(clients *test.Clients, pod *corev1.Pod, _ logging.FormatLogger, cleaner *test.Cleaner) error

CreatePod will create a Pod

func CreateRouteAndConfig

func CreateRouteAndConfig(clients *test.Clients, logf logging.FormatLogger, cleaner *test.Cleaner, name string, imagePath string) error

CreateRouteAndConfig will create Route and Config objects using clients. The Config object will serve requests to a container started from the image at imagePath.

func CreateService

func CreateService(clients *test.Clients, svc *corev1.Service, _ logging.FormatLogger, cleaner *test.Cleaner) error

CreateService will create a Service

func CreateServiceAccount

func CreateServiceAccount(clients *test.Clients, sa *corev1.ServiceAccount, _ logging.FormatLogger, cleaner *test.Cleaner) error

CreateServiceAccount will create a service account

func CreateServiceAccountAndBinding

func CreateServiceAccountAndBinding(clients *test.Clients, name string, logf logging.FormatLogger, cleaner *test.Cleaner) error

CreateServiceAccountAndBinding creates both ServiceAccount and ClusterRoleBinding with default cluster-admin role

func CreateSubscription

func CreateSubscription(clients *test.Clients, sub *v1alpha1.Subscription, _ logging.FormatLogger, cleaner *test.Cleaner) error

CreateSubscription will create a Subscription

func CreateTrigger

func CreateTrigger(clients *test.Clients, trigger *v1alpha1.Trigger, logf logging.FormatLogger, cleaner *test.Cleaner) error

CreateTrigger will create a Trigger.

func FindAnyLogContents

func FindAnyLogContents(clients *test.Clients, logf logging.FormatLogger, podName string, containerName string, namespace string, contents []string) (bool, error)

FindAnyLogContents attempts to find logs for given Pod/Container that has 'any' of the given contents. It returns an error if it couldn't retrieve the logs. In case 'any' of the contents are there, it returns true.

func LabelNamespace

func LabelNamespace(clients *test.Clients, logf logging.FormatLogger, labels map[string]string) error

LabelNamespace labels the test namespace with the labels map.

func NamespaceExists

func NamespaceExists(t *testing.T, clients *test.Clients, logf logging.FormatLogger) (string, func())

func Setup

func Setup(t *testing.T, logf logging.FormatLogger) (*test.Clients, *test.Cleaner)

Setup creates the client objects needed in the e2e tests.

func TearDown

func TearDown(clients *test.Clients, cleaner *test.Cleaner, _ logging.FormatLogger)

TearDown will delete created names using clients.

func WaitForAllTriggersReady

func WaitForAllTriggersReady(clients *test.Clients, logf logging.FormatLogger, namespace string) error

WaitForAllTriggersReady will wait until all triggers in the given namespace are ready.

func WaitForBrokerReady

func WaitForBrokerReady(clients *test.Clients, broker *v1alpha1.Broker) error

WaitForBrokerReady waits until the broker is Ready.

func WaitForLogContents

func WaitForLogContents(clients *test.Clients, logf logging.FormatLogger, podName string, containerName string, namespace string, contents []string) error

WaitForLogContents waits until logs for given Pod/Container include the given contents. If the contents are not present within timeout it returns error.

func WithBrokerReady

func WithBrokerReady(clients *test.Clients, broker *v1alpha1.Broker, logf logging.FormatLogger, cleaner *test.Cleaner) error

WithBrokerReady creates a Broker and waits until it is Ready.

func WithChannelAndSubscriptionReady

func WithChannelAndSubscriptionReady(clients *test.Clients, channel *v1alpha1.Channel, sub *v1alpha1.Subscription, logf logging.FormatLogger, cleaner *test.Cleaner) error

WithChannelAndSubscriptionReady creates a Channel and Subscription and waits until both are Ready.

func WithRouteReady

func WithRouteReady(clients *test.Clients, logf logging.FormatLogger, cleaner *test.Cleaner, name string, imagePath string) error

WithRouteReady will create Route and Config objects and wait until they're ready.

func WithTriggerReady

func WithTriggerReady(clients *test.Clients, trigger *v1alpha1.Trigger, logf logging.FormatLogger, cleaner *test.Cleaner) error

WithTriggerReady creates a Trigger and waits until it is Ready.