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

Functions

func BrokerChannelFlowTestHelper

func BrokerChannelFlowTestHelper(t *testing.T, channelTestRunner common.ChannelTestRunner)

BrokerChannelFlowTestHelper is the helper function for broker_channel_flow_test

func ChannelChainTestHelper

func ChannelChainTestHelper(t *testing.T, channelTestRunner common.ChannelTestRunner)

ChannelChainTestHelper is the helper function for channel_chain_test

func ChannelClusterDefaulterTestHelper

func ChannelClusterDefaulterTestHelper(t *testing.T, channelTestRunner common.ChannelTestRunner)

ChannelClusterDefaulterTestHelper is the helper function for channel_defaulter_test

func ChannelDeadLetterSinkTestHelper

func ChannelDeadLetterSinkTestHelper(t *testing.T, channelTestRunner common.ChannelTestRunner)

ChannelDeadLetterSinkTestHelper is the helper function for channel_deadlettersink_test

func ChannelNamespaceDefaulterTestHelper

func ChannelNamespaceDefaulterTestHelper(t *testing.T, channelTestRunner common.ChannelTestRunner)

ChannelNamespaceDefaulterTestHelper is the helper function for channel_defaulter_test

func EventTransformationForSubscriptionTestHelper

func EventTransformationForSubscriptionTestHelper(t *testing.T, channelTestRunner common.ChannelTestRunner)

EventTransformationForSubscriptionTestHelper is the helper function for channel_event_tranformation_test

func EventTransformationForTriggerTestHelper

func EventTransformationForTriggerTestHelper(t *testing.T, channelTestRunner common.ChannelTestRunner)

EventTransformationForTriggerTestHelper is the helper function for broker_event_tranformation_test

func SetupPerformanceImageRBAC

func SetupPerformanceImageRBAC(client *common.Client)

func SingleEventForChannelTestHelper

func SingleEventForChannelTestHelper(t *testing.T, encoding string, channelTestRunner common.ChannelTestRunner)

SingleEventForChannelTestHelper is the helper function for channel_single_event_test

func TestWithPerformanceImage

func TestWithPerformanceImage(st *testing.T, expectedAggregatorRecords int, setupEnv func(t *testing.T, consumerHostname string, aggregatorHostname string, client *common.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
}