README
¶
End to end 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:
- Provide frequent output describing what actions they are undertaking, especially before performing long running operations.
- 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 CreateNamespaceIfNeeded(t *testing.T, clients *test.Clients, logf logging.FormatLogger) (string, func())
- func CreatePod(clients *test.Clients, pod *corev1.Pod, _ logging.FormatLogger, ...) error
- func CreatePodAndServiceReady(clients *test.Clients, pod *corev1.Pod, svc *corev1.Service, ns string, ...) (*corev1.Pod, 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 SendFakeEventToChannel(clients *test.Clients, event *test.CloudEvent, channel *v1alpha1.Channel, ...) error
- 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 WaitForLogContentCount(client *test.Clients, podName, containerName, content string, appearTimes int) 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 WithChannelsAndSubscriptionsReady(clients *test.Clients, chans *[]*v1alpha1.Channel, ...) error
- func WithTriggerReady(clients *test.Clients, trigger *v1alpha1.Trigger, logf logging.FormatLogger, ...) error
Constants ¶
const (
DefaultTestNamespace = "e2etest-knative-eventing"
)
Variables ¶
This section is empty.
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 CreateNamespaceIfNeeded ¶
func CreateNamespaceIfNeeded(t *testing.T, clients *test.Clients, logf logging.FormatLogger) (string, func())
CreateNamespaceIfNeeded creates a new namespace if it does not exist
func CreatePod ¶
func CreatePod(clients *test.Clients, pod *corev1.Pod, _ logging.FormatLogger, cleaner *test.Cleaner) error
CreatePod will create a Pod
func CreatePodAndServiceReady ¶
func CreatePodAndServiceReady(clients *test.Clients, pod *corev1.Pod, svc *corev1.Service, ns string, logf logging.FormatLogger, cleaner *test.Cleaner) (*corev1.Pod, error)
CreatePodAndServiceReady will create a Pod and Service, and wait for them to become ready
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 SendFakeEventToChannel ¶
func SendFakeEventToChannel(clients *test.Clients, event *test.CloudEvent, channel *v1alpha1.Channel, ns string, logf logging.FormatLogger, cleaner *test.Cleaner) error
SendFakeEventToChannel will create fake CloudEvent and send it to the given channel.
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 ¶
WaitForBrokerReady waits until the broker is Ready.
func WaitForLogContentCount ¶
func WaitForLogContentCount(client *test.Clients, podName, containerName, content string, appearTimes int) error
WaitForLogContentCount checks if the number of substr occur times equals the given number. If the content does not appear the given times it returns error.
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 WithChannelsAndSubscriptionsReady ¶
func WithChannelsAndSubscriptionsReady(clients *test.Clients, chans *[]*v1alpha1.Channel, subs *[]*v1alpha1.Subscription, logf logging.FormatLogger, cleaner *test.Cleaner) error
WithChannelsAndSubscriptionsReady creates Channels and Subscriptions and waits until all are Ready. When they are ready, chans and subs are altered to get the real Channels and Subscriptions.
Types ¶
This section is empty.
Source Files