helpers

README

helpers

This package contains helper functions that are used in the actual tests. These functions can be referenced in other repositories (like eventing-contrib) for adding similar tests.

Documentation

Index

• func BrokerChannelFlowWithTransformation(t *testing.T, brokerClass string, brokerVersion string, triggerVersion string, ...)
• func BrokerRedelivery(t *testing.T, creator BrokerCreatorWithRetries)
• func ChannelChainTestHelper(t *testing.T, subscriptionVersion SubscriptionVersion, ...)
• func ChannelClusterDefaulterTestHelper(t *testing.T, channelTestRunner testlib.ComponentsTestRunner, ...)
• func ChannelDeadLetterSinkTestHelper(t *testing.T, subscriptionVersion SubscriptionVersion, ...)
• func ChannelNamespaceDefaulterTestHelper(t *testing.T, channelTestRunner testlib.ComponentsTestRunner, ...)
• func EventTransformationForSubscriptionTestHelper(t *testing.T, subscriptionVersion SubscriptionVersion, ...)
• func EventTransformationForTriggerTestHelper(t *testing.T, brokerVersion string, triggerVersion string, ...)
• func ParallelTestHelper(t *testing.T, channelTestRunner testlib.ComponentsTestRunner, ...)
• func ParallelV1TestHelper(t *testing.T, channelTestRunner testlib.ComponentsTestRunner, ...)
• func SequenceTestHelper(t *testing.T, channelTestRunner testlib.ComponentsTestRunner, ...)
• func SequenceV1TestHelper(t *testing.T, channelTestRunner testlib.ComponentsTestRunner, ...)
• func SingleEventForChannelTestHelper(t *testing.T, encoding cloudevents.Encoding, ...)
• func TestBrokerWithManyTriggers(t *testing.T, brokerCreator BrokerCreator, shouldLabelNamespace bool)
• func TestTriggerNoBroker(t *testing.T, channel string, brokerCreator BrokerCreator)
• type BrokerCreator
  • func ChannelBasedBrokerCreator(channel metav1.TypeMeta, brokerClass string) BrokerCreator
• type BrokerCreatorWithRetries
• type SubscriptionVersion

Functions

func BrokerChannelFlowWithTransformation

func BrokerChannelFlowWithTransformation(t *testing.T,
	brokerClass string,
	brokerVersion string,
	triggerVersion string,
	channelTestRunner testlib.ComponentsTestRunner,
	options ...testlib.SetupClientOption)

BrokerChannelFlowWithTransformation tests the following topology:

------------- ----------------------
|           | |                    |
v	       | v                    |

EventSource ---> Broker ---> Trigger1 -------> Service(Transformation)

|
|
|-------> Trigger2 -------> Service(Logger1)
|
|
|-------> Trigger3 -------> Channel --------> Subscription --------> Service(Logger2)

Explanation: Trigger1 filters the orignal event and tranforms it to a new event, Trigger2 logs all events, Trigger3 filters the transformed event and sends it to Channel.

func BrokerRedelivery

func BrokerRedelivery(t *testing.T, creator BrokerCreatorWithRetries)

func ChannelChainTestHelper

func ChannelChainTestHelper(t *testing.T,
	subscriptionVersion SubscriptionVersion,
	channelTestRunner testlib.ComponentsTestRunner,
	options ...testlib.SetupClientOption)

ChannelChainTestHelper is the helper function for channel_chain_test

func ChannelClusterDefaulterTestHelper

func ChannelClusterDefaulterTestHelper(t *testing.T,
	channelTestRunner testlib.ComponentsTestRunner,
	options ...testlib.SetupClientOption)

ChannelClusterDefaulterTestHelper is the helper function for channel_defaulter_test

func ChannelDeadLetterSinkTestHelper

func ChannelDeadLetterSinkTestHelper(t *testing.T,
	subscriptionVersion SubscriptionVersion,
	channelTestRunner testlib.ComponentsTestRunner,
	options ...testlib.SetupClientOption)

ChannelDeadLetterSinkTestHelper is the helper function for channel_deadlettersink_test

func ChannelNamespaceDefaulterTestHelper

func ChannelNamespaceDefaulterTestHelper(t *testing.T,
	channelTestRunner testlib.ComponentsTestRunner,
	options ...testlib.SetupClientOption)

ChannelNamespaceDefaulterTestHelper is the helper function for channel_defaulter_test

func EventTransformationForSubscriptionTestHelper

func EventTransformationForSubscriptionTestHelper(t *testing.T,
	subscriptionVersion SubscriptionVersion,
	channelTestRunner testlib.ComponentsTestRunner,
	options ...testlib.SetupClientOption)

EventTransformationForSubscriptionTestHelper is the helper function for channel_event_tranformation_test

func EventTransformationForTriggerTestHelper

func EventTransformationForTriggerTestHelper(t *testing.T,
	brokerVersion string,
	triggerVersion string,
	creator BrokerCreator,
	options ...testlib.SetupClientOption)

EventTransformationForTriggerTestHelper tests the following scenario:

            5                 4
      ------------- ----------------------
      |           | |                    |
1     v	 2     | v        3           |

EventSource ---> Broker ---> Trigger1 -------> Service(Transformation)

|
| 6                   7
|-------> Trigger2 -------> Service(Logger)

Note: the number denotes the sequence of the event that flows in this test case.

func ParallelTestHelper

func ParallelTestHelper(t *testing.T,
	channelTestRunner testlib.ComponentsTestRunner,
	options ...testlib.SetupClientOption)

func ParallelV1TestHelper

func ParallelV1TestHelper(t *testing.T,
	channelTestRunner testlib.ComponentsTestRunner,
	options ...testlib.SetupClientOption)

func SequenceTestHelper

func SequenceTestHelper(t *testing.T,
	channelTestRunner testlib.ComponentsTestRunner,
	options ...testlib.SetupClientOption)

func SequenceV1TestHelper

func SequenceV1TestHelper(t *testing.T,
	channelTestRunner testlib.ComponentsTestRunner,
	options ...testlib.SetupClientOption)

func SingleEventForChannelTestHelper

func SingleEventForChannelTestHelper(t *testing.T, encoding cloudevents.Encoding,
	subscriptionVersion SubscriptionVersion,
	channelVersion string,
	channelTestRunner testlib.ComponentsTestRunner,
	options ...testlib.SetupClientOption)

SingleEventForChannelTestHelper is the helper function for channel_single_event_test channelVersion can be used to override which version you want to create the subscription against. For example, you could create a v1beta1 channel, but create a subscription to its v1alpha1 version by using channelVersion to override it. channelVersion == "" means that the version of the channel subscribed to is not modified.

func TestBrokerWithManyTriggers

func TestBrokerWithManyTriggers(t *testing.T, brokerCreator BrokerCreator, shouldLabelNamespace bool)

If shouldLabelNamespace is set to true this test annotates the testing namespace so that a default broker is created. It then binds many triggers with different filtering patterns to the broker created by brokerCreator, and sends different events to the broker's address. Finally, it verifies that only the appropriate events are routed to the subscribers.

func TestTriggerNoBroker

func TestTriggerNoBroker(t *testing.T, channel string, brokerCreator BrokerCreator)

TestTriggerNoBroker will create a Trigger with a non-existent broker, then it will ensure the Status is correctly reflected as failed with BrokerDoesNotExist. Then it will create the broker and ensure that Trigger / Broker will get to Ready state.

Types

type BrokerCreator

type BrokerCreator func(client *testlib.Client, version string) string

BrokerCreator creates a broker and returns its broker name. TestBrokerWithManyTriggers will wait for the broker to become ready.

func ChannelBasedBrokerCreator

func ChannelBasedBrokerCreator(channel metav1.TypeMeta, brokerClass string) BrokerCreator

ChannelBasedBrokerCreator creates a BrokerCreator that creates a broker based on the channel parameter.

type BrokerCreatorWithRetries

type BrokerCreatorWithRetries func(client *testlib.Client, numRetries int32) string

BrokerCreator creates a broker and returns its broker name.

type SubscriptionVersion

type SubscriptionVersion string

const (
	SubscriptionV1beta1 SubscriptionVersion = "v1beta1"
	SubscriptionV1      SubscriptionVersion = "v1"
)