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, channelTestRunner lib.ChannelTestRunner, ...)
- func TestWithPerformanceImage(st *testing.T, expectedAggregatorRecords int, ...)
- type PerformanceImageResults
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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 ¶ added in v0.12.0
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 ¶ added in v0.11.0
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 ¶ added in v0.11.0
func SingleEventForChannelTestHelper ¶
func SingleEventForChannelTestHelper(t *testing.T, encoding string, channelTestRunner lib.ChannelTestRunner, options ...lib.SetupClientOption)
SingleEventForChannelTestHelper is the helper function for channel_single_event_test
func TestWithPerformanceImage ¶ added in v0.11.0
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