helpers

Documentation

Index

• func BrokerTracingTestHelper(t *testing.T, channel metav1.TypeMeta, setupClient SetupClientFunc)
• func BrokerTracingTestHelperWithChannelTestRunner(t *testing.T, channelTestRunner common.ChannelTestRunner, ...)
• func ChannelTracingTestHelper(t *testing.T, channel metav1.TypeMeta, setupClient SetupClientFunc)
• func ChannelTracingTestHelperWithChannelTestRunner(t *testing.T, channelTestRunner common.ChannelTestRunner, ...)
• func SingleEventHelperForChannelTestHelper(t *testing.T, encoding string, channelTestRunner common.ChannelTestRunner)
• type SetupClientFunc
• type SetupInfrastructureFunc
• type TracingTestCase

Functions

func BrokerTracingTestHelper

func BrokerTracingTestHelper(t *testing.T, channel metav1.TypeMeta, setupClient SetupClientFunc)

BrokerTracingTestHelper runs the Broker tracing test using the given TypeMeta.

func BrokerTracingTestHelperWithChannelTestRunner

func BrokerTracingTestHelperWithChannelTestRunner(
	t *testing.T,
	channelTestRunner common.ChannelTestRunner,
	setupClient SetupClientFunc,
)

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

func ChannelTracingTestHelper

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

ChannelTracingTestHelper runs the Channel tracing test using the given TypeMeta.

func ChannelTracingTestHelperWithChannelTestRunner

func ChannelTracingTestHelperWithChannelTestRunner(
	t *testing.T,
	channelTestRunner common.ChannelTestRunner,
	setupClient SetupClientFunc,
)

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

func SingleEventHelperForChannelTestHelper

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

SingleEventHelperForChannelTestHelper is the helper function for header_test

Types

type SetupClientFunc

type SetupClientFunc func(*common.Client) error

SetupClientFunc sets up the client for running tracing tests. It does the equivalent of client.Setup().

var SetupClientFuncNoop SetupClientFunc = func(*common.Client) error {
	return nil
}

SetupClientFuncNoop is a SetupClientFunc that does nothing.

type SetupInfrastructureFunc

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

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.