helpers

Documentation

Index

• Constants
• func BrokerDataPlaneSetupHelper(client *testlib.Client, brokerName, brokerNamespace, brokerClass string) *eventingv1beta1.Broker
• func BrokerTracingTestHelperWithChannelTestRunner(t *testing.T, brokerClass string, ...)
• func BrokerV1Beta1ConsumerDataPlaneTestHelper(t *testing.T, client *testlib.Client, broker *eventingv1beta1.Broker)
• func BrokerV1Beta1ControlPlaneTest(t *testing.T, brokerCreator BrokerCreator, ...)
• func BrokerV1Beta1IngressDataPlaneTestHelper(t *testing.T, client *testlib.Client, broker *eventingv1beta1.Broker)
• func ChannelCRDMetadataTestHelperWithChannelTestRunner(t *testing.T, channelTestRunner testlib.ComponentsTestRunner, ...)
• func ChannelCRDNameTestHelperWithChannelTestRunner(t *testing.T, channelTestRunner testlib.ComponentsTestRunner, ...)
• func ChannelDataPlaneFailureTestRunner(t *testing.T, channelTestRunner testlib.ComponentsTestRunner, ...)
• func ChannelDataPlaneSuccessTestRunner(t *testing.T, channelTestRunner testlib.ComponentsTestRunner, ...)
• func ChannelSpecTestHelperWithChannelTestRunner(t *testing.T, channelTestRunner testlib.ComponentsTestRunner, ...)
• func ChannelStatusSubscriberTestHelperWithChannelTestRunner(t *testing.T, channelTestRunner testlib.ComponentsTestRunner, ...)
• func ChannelStatusTestHelperWithChannelTestRunner(t *testing.T, channelTestRunner testlib.ComponentsTestRunner, ...)
• func ChannelTracingTestHelperWithChannelTestRunner(t *testing.T, channelTestRunner testlib.ComponentsTestRunner, ...)
• func ServiceAccountCanDoVerbOnResourceOrFail(client *testlib.Client, gvr schema.GroupVersionResource, subresource string, ...)
• func SingleEventWithKnativeHeaderHelperForChannelTestHelper(t *testing.T, encoding cloudevents.Encoding, ...)
• func TestChannelAddressableResolverClusterRoleTestRunner(t *testing.T, channelTestRunner testlib.ComponentsTestRunner, ...)
• func TestChannelChannelableManipulatorClusterRoleTestRunner(t *testing.T, channelTestRunner testlib.ComponentsTestRunner, ...)
• func ValidateRequiredLabels(client *testlib.Client, object metav1.TypeMeta, labels map[string]string)
• type BrokerCreator
• type SetupTracingTestInfrastructureFunc

Constants

const (
	ChannelNameSuffix = "Channel"
)

Functions

func BrokerDataPlaneSetupHelper

func BrokerDataPlaneSetupHelper(client *testlib.Client, brokerName, brokerNamespace, brokerClass string) *eventingv1beta1.Broker

func BrokerTracingTestHelperWithChannelTestRunner

func BrokerTracingTestHelperWithChannelTestRunner(
	t *testing.T,
	brokerClass string,
	channelTestRunner testlib.ComponentsTestRunner,
	setupClient testlib.SetupClientOption,
)

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

func BrokerV1Beta1ConsumerDataPlaneTestHelper

func BrokerV1Beta1ConsumerDataPlaneTestHelper(
	t *testing.T,
	client *testlib.Client,
	broker *eventingv1beta1.Broker,
)

At consumer No upgrade of version Attributes received should be the same as produced (attributes may be added) Events are filtered Events are delivered to multiple subscribers Deliveries succeed at least once Replies are accepted and delivered Replies that are unsuccessfully forwarded cause initial message to be redelivered (Very difficult to test, can be ignored)

func BrokerV1Beta1ControlPlaneTest

func BrokerV1Beta1ControlPlaneTest(
	t *testing.T,
	brokerCreator BrokerCreator,
	setupClient ...testlib.SetupClientOption,
)

This tests if the broker control plane: 1. Trigger can be created before Broker (with attributes filter) 2. Broker can be created and progresses to Ready 3. Ready Broker is Addressable 4. Trigger with Ready broker progresses to Ready 5. Trigger with no broker, updated with broker, updates status to include subscriberURI 6. Ready Trigger includes status.subscriberUri

func BrokerV1Beta1IngressDataPlaneTestHelper

func BrokerV1Beta1IngressDataPlaneTestHelper(
	t *testing.T,
	client *testlib.Client,
	broker *eventingv1beta1.Broker,
)

At ingress Supports CE 0.3 or CE 1.0 via HTTP Supports structured or Binary mode Respond with 2xx on good CE Respond with 400 on bad CE Reject non-POST requests to publish URI

func ChannelCRDMetadataTestHelperWithChannelTestRunner

func ChannelCRDMetadataTestHelperWithChannelTestRunner(
	t *testing.T,
	channelTestRunner testlib.ComponentsTestRunner,
	options ...testlib.SetupClientOption,
)

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

func ChannelCRDNameTestHelperWithChannelTestRunner

func ChannelCRDNameTestHelperWithChannelTestRunner(
	t *testing.T,
	channelTestRunner testlib.ComponentsTestRunner,
	options ...testlib.SetupClientOption,
)

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

func ChannelDataPlaneFailureTestRunner

func ChannelDataPlaneFailureTestRunner(
	t *testing.T,
	channelTestRunner testlib.ComponentsTestRunner,
	options ...testlib.SetupClientOption,
)

ChannelDataPlaneFailureTestRunner tests some status codes from the spec

func ChannelDataPlaneSuccessTestRunner

func ChannelDataPlaneSuccessTestRunner(
	t *testing.T,
	channelTestRunner testlib.ComponentsTestRunner,
	options ...testlib.SetupClientOption,
)

ChannelDataPlaneSuccessTestRunner tests the support of the channel ingress for different spec versions and message modes

func ChannelSpecTestHelperWithChannelTestRunner

func ChannelSpecTestHelperWithChannelTestRunner(
	t *testing.T,
	channelTestRunner testlib.ComponentsTestRunner,
	options ...testlib.SetupClientOption,
)

func ChannelStatusSubscriberTestHelperWithChannelTestRunner

func ChannelStatusSubscriberTestHelperWithChannelTestRunner(
	t *testing.T,
	channelTestRunner testlib.ComponentsTestRunner,
	options ...testlib.SetupClientOption,
)

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

func ChannelStatusTestHelperWithChannelTestRunner

func ChannelStatusTestHelperWithChannelTestRunner(
	t *testing.T,
	channelTestRunner testlib.ComponentsTestRunner,
	options ...testlib.SetupClientOption,
)

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

func ChannelTracingTestHelperWithChannelTestRunner

func ChannelTracingTestHelperWithChannelTestRunner(
	t *testing.T,
	channelTestRunner testlib.ComponentsTestRunner,
	setupClient testlib.SetupClientOption,
)

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

func ServiceAccountCanDoVerbOnResourceOrFail

func ServiceAccountCanDoVerbOnResourceOrFail(client *testlib.Client, gvr schema.GroupVersionResource, subresource string, saName string, verb string)

func SingleEventWithKnativeHeaderHelperForChannelTestHelper

func SingleEventWithKnativeHeaderHelperForChannelTestHelper(
	t *testing.T,
	encoding cloudevents.Encoding,
	channelTestRunner testlib.ComponentsTestRunner,
	options ...testlib.SetupClientOption,
)

SingleEventWithKnativeHeaderHelperForChannelTestHelper is the helper function for header_test

func TestChannelAddressableResolverClusterRoleTestRunner

func TestChannelAddressableResolverClusterRoleTestRunner(
	t *testing.T,
	channelTestRunner testlib.ComponentsTestRunner,
	options ...testlib.SetupClientOption,
)

func TestChannelChannelableManipulatorClusterRoleTestRunner

func TestChannelChannelableManipulatorClusterRoleTestRunner(
	t *testing.T,
	channelTestRunner testlib.ComponentsTestRunner,
	options ...testlib.SetupClientOption,
)

func ValidateRequiredLabels

func ValidateRequiredLabels(client *testlib.Client, object metav1.TypeMeta, labels map[string]string)

Types

type BrokerCreator

type BrokerCreator func(client *testlib.Client, name string)

Creates a Broker with the given name.

type SetupTracingTestInfrastructureFunc

type SetupTracingTestInfrastructureFunc func(
	t *testing.T,
	channel *metav1.TypeMeta,
	client *testlib.Client,
	loggerPodName string,
	senderPublishTrace bool,
) (tracinghelper.TestSpanTree, cetest.EventMatcher)

SetupTracingTestInfrastructureFunc 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.