helpers

Documentation

Index

• Constants
• func BrokerTracingTestHelper(t *testing.T, brokerClass string, channel metav1.TypeMeta, ...)
• func BrokerTracingTestHelperWithChannelTestRunner(t *testing.T, brokerClass string, channelTestRunner lib.ChannelTestRunner, ...)
• func ChannelCRDMetadataTestHelperWithChannelTestRunner(t *testing.T, channelTestRunner lib.ChannelTestRunner, ...)
• func ChannelCRDNameTestHelperWithChannelTestRunner(t *testing.T, channelTestRunner lib.ChannelTestRunner, ...)
• func ChannelSpecTestHelperWithChannelTestRunner(t *testing.T, channelTestRunner lib.ChannelTestRunner, ...)
• func ChannelStatusSubscriberTestHelperWithChannelTestRunner(t *testing.T, channelTestRunner lib.ChannelTestRunner, ...)
• func ChannelStatusTestHelperWithChannelTestRunner(t *testing.T, channelTestRunner lib.ChannelTestRunner, ...)
• func ChannelTracingTestHelper(t *testing.T, channel metav1.TypeMeta, setupClient lib.SetupClientOption)
• func ChannelTracingTestHelperWithChannelTestRunner(t *testing.T, channelTestRunner lib.ChannelTestRunner, ...)
• func SingleEventHelperForChannelTestHelper(t *testing.T, encoding string, channelTestRunner lib.ChannelTestRunner, ...)
• func TestChannelChannelableManipulatorClusterRoleTestRunner(t *testing.T, channelTestRunner lib.ChannelTestRunner, ...)
• type SetupInfrastructureFunc
• type TracingTestCase

Constants

const (
	ChannelNameSuffix = "Channel"
)

const (
	SubscribableAnnotationKey = "messaging.knative.dev/subscribable"
)

Functions

func BrokerTracingTestHelper

func BrokerTracingTestHelper(t *testing.T, brokerClass string, channel metav1.TypeMeta, setupClient lib.SetupClientOption)

BrokerTracingTestHelper runs the Broker tracing test using the given TypeMeta.

func BrokerTracingTestHelperWithChannelTestRunner

func BrokerTracingTestHelperWithChannelTestRunner(
	t *testing.T,
	brokerClass string,
	channelTestRunner lib.ChannelTestRunner,
	setupClient lib.SetupClientOption,
)

BrokerTracingTestHelperWithChannelTestRunner runs the Broker tracing tests for all Channels in the ChannelTestRunner.

func ChannelCRDMetadataTestHelperWithChannelTestRunner

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

ChannelCRDMetadataTestHelperWithChannelTestRunner runs the Channel CRD metadata tests for all Channel resources in the ChannelTestRunner.

func ChannelCRDNameTestHelperWithChannelTestRunner

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

ChannelCRDNameTestHelperWithChannelTestRunner runs the Channel CRD name tests for all Channel resources in the ChannelTestRunner.

func ChannelSpecTestHelperWithChannelTestRunner

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

func ChannelStatusSubscriberTestHelperWithChannelTestRunner

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

ChannelStatusSubscriberTestHelperWithChannelTestRunner runs the tests of subscriber field of status for all Channels in the ChannelTestRunner.

func ChannelStatusTestHelperWithChannelTestRunner

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

ChannelStatusTestHelperWithChannelTestRunner runs the Channel status tests for all Channels in the ChannelTestRunner.

func ChannelTracingTestHelper

func ChannelTracingTestHelper(t *testing.T, channel metav1.TypeMeta, setupClient lib.SetupClientOption)

ChannelTracingTestHelper runs the Channel tracing test using the given TypeMeta.

func ChannelTracingTestHelperWithChannelTestRunner

func ChannelTracingTestHelperWithChannelTestRunner(
	t *testing.T,
	channelTestRunner lib.ChannelTestRunner,
	setupClient lib.SetupClientOption,
)

ChannelTracingTestHelperWithChannelTestRunner runs the Channel tracing tests for all Channels in the ChannelTestRunner.

func SingleEventHelperForChannelTestHelper

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

SingleEventHelperForChannelTestHelper is the helper function for header_test

func TestChannelChannelableManipulatorClusterRoleTestRunner

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

Types

type SetupInfrastructureFunc

type SetupInfrastructureFunc func(
	t *testing.T,
	channel *metav1.TypeMeta,
	client *lib.Client,
	loggerPodName string,
	tc TracingTestCase,
) (tracinghelper.TestSpanTree, lib.EventMatchFunc)

SetupInfrastructureFunc sets up the infrastructure for running tracing tests. It returns the expected trace as well as a string that is expected to be in the logger Pod's logs.

type TracingTestCase

type TracingTestCase struct {
	// IncomingTraceId controls whether the original request is sent to the Broker/Channel already
	// has a trace ID associated with it by the sender.
	IncomingTraceId bool
	// Istio controls whether the Pods being created for the test (sender, transformer, logger,
	// etc.) have Istio sidecars. It does not affect the Channel Pods.
	Istio bool
}

TracingTestCase is the test case information for tracing tests.