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 BrokerChannelFlowTestHelper(t *testing.T, channelTestRunner lib.ChannelTestRunner, ...)
• func BrokerDeadLetterSinkTestHelper(t *testing.T, channelTestRunner lib.ChannelTestRunner, ...)
• func ChannelChainTestHelper(t *testing.T, channelTestRunner lib.ChannelTestRunner, ...)
• func ChannelClusterDefaulterTestHelper(t *testing.T, channelTestRunner lib.ChannelTestRunner, ...)
• func ChannelDeadLetterSinkTestHelper(t *testing.T, channelTestRunner lib.ChannelTestRunner, ...)
• func ChannelNamespaceDefaulterTestHelper(t *testing.T, channelTestRunner lib.ChannelTestRunner, ...)
• func EventTransformationForSubscriptionTestHelper(t *testing.T, channelTestRunner lib.ChannelTestRunner, ...)
• func EventTransformationForTriggerTestHelper(t *testing.T, channelTestRunner lib.ChannelTestRunner, ...)
• func SetupPerformanceImageRBAC(client *lib.Client)
• func SingleEventForChannelTestHelper(t *testing.T, encoding string, subscriptionVersion subscriptionVersion, ...)
• func TestBrokerWithConfig(t *testing.T, channelTestRunner lib.ChannelTestRunner, ...)
• func TestWithPerformanceImage(st *testing.T, expectedAggregatorRecords int, ...)
• type PerformanceImageResults

Functions

func BrokerChannelFlowTestHelper

func BrokerChannelFlowTestHelper(t *testing.T,
	channelTestRunner lib.ChannelTestRunner,
	options ...lib.SetupClientOption)

BrokerChannelFlowTestHelper is the helper function for broker_channel_flow_test

func BrokerDeadLetterSinkTestHelper

func BrokerDeadLetterSinkTestHelper(t *testing.T,
	channelTestRunner lib.ChannelTestRunner,
	options ...lib.SetupClientOption)

BrokerDeadLetterSinkTestHelper is the helper function for broker_dls_test

func ChannelChainTestHelper

func ChannelChainTestHelper(t *testing.T,
	channelTestRunner lib.ChannelTestRunner,
	options ...lib.SetupClientOption)

ChannelChainTestHelper is the helper function for channel_chain_test

func ChannelClusterDefaulterTestHelper

func ChannelClusterDefaulterTestHelper(t *testing.T,
	channelTestRunner lib.ChannelTestRunner,
	options ...lib.SetupClientOption)

ChannelClusterDefaulterTestHelper is the helper function for channel_defaulter_test

func ChannelDeadLetterSinkTestHelper

func ChannelDeadLetterSinkTestHelper(t *testing.T,
	channelTestRunner lib.ChannelTestRunner,
	options ...lib.SetupClientOption)

ChannelDeadLetterSinkTestHelper is the helper function for channel_deadlettersink_test

func ChannelNamespaceDefaulterTestHelper

func ChannelNamespaceDefaulterTestHelper(t *testing.T,
	channelTestRunner lib.ChannelTestRunner,
	options ...lib.SetupClientOption)

ChannelNamespaceDefaulterTestHelper is the helper function for channel_defaulter_test

func EventTransformationForSubscriptionTestHelper

func EventTransformationForSubscriptionTestHelper(t *testing.T,
	channelTestRunner lib.ChannelTestRunner,
	options ...lib.SetupClientOption)

EventTransformationForSubscriptionTestHelper is the helper function for channel_event_tranformation_test

func EventTransformationForTriggerTestHelper

func EventTransformationForTriggerTestHelper(t *testing.T,
	channelTestRunner lib.ChannelTestRunner,
	options ...lib.SetupClientOption)

EventTransformationForTriggerTestHelper is the helper function for broker_event_tranformation_test

func SetupPerformanceImageRBAC

func SetupPerformanceImageRBAC(client *lib.Client)

func SingleEventForChannelTestHelper

func SingleEventForChannelTestHelper(t *testing.T, encoding string,
	subscriptionVersion subscriptionVersion,
	channelTestRunner lib.ChannelTestRunner,
	options ...lib.SetupClientOption)

SingleEventForChannelTestHelper is the helper function for channel_single_event_test

func TestBrokerWithConfig

func TestBrokerWithConfig(t *testing.T,
	channelTestRunner lib.ChannelTestRunner,
	options ...lib.SetupClientOption)

TestBrokerWithConfig is the helper function for broker_with_config_test

func TestWithPerformanceImage

func TestWithPerformanceImage(st *testing.T, expectedAggregatorRecords int, setupEnv func(t *testing.T, consumerHostname string, aggregatorHostname string, client *lib.Client), assertResults func(*testing.T, *PerformanceImageResults))

This function setups RBAC, services and aggregator pod. It DOESN'T setup channel, broker nor sender and receiver pod(s). The setup of these resources MUST be done inside `setupEnv` function

Types

type PerformanceImageResults

type PerformanceImageResults struct {
	SentEvents             uint64
	AcceptedEvents         uint64
	ReceivedEvents         uint64
	PublishFailuresEvents  uint64
	DeliveryFailuresEvents uint64
}