kafkachannel

package
v0.39.4 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 22, 2024 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

View Source
const (
	TestNameKey     = "TestNameKey"
	ReceiverNameKey = "ReceiverNameKey"
	SenderNameKey   = "SenderNameKey"
	SenderSinkKey   = "SenderSinkKey"
)

Variables

This section is empty.

Functions

func ConfigureDataPlane

func ConfigureDataPlane(ctx context.Context, t *testing.T) *feature.Feature

ConfigureDataPlane creates a Feature which sets up the specified KafkaChannel Subscription and EventsHub Receiver so that it is ready to receive CloudEvents.

func ReceiverName

func ReceiverName(ctx context.Context, t *testing.T) string

ReceiverName returns the name of the EventsHub Receiver associated with the Context for the test.

func SendEvents

func SendEvents(ctx context.Context, t *testing.T, eventCount int, startId int, endId int) *feature.Feature

SendEvents creates a Feature which sends a number of CloudEvents to the specified KafkaChannel and verifies their receipt in the corresponding EventsHub Receiver. It is assumed that the backing KafkaChannel / Subscription / Receiver are in place and ready to receive these events.

func SenderName

func SenderName(ctx context.Context, t *testing.T) string

SenderName returns the name of the EventsHub Sender associated with the Context for the test.

func SenderSink

func SenderSink(ctx context.Context, t *testing.T) string

SenderSink returns the destination sink of the EventsHub Sender's to which events will be sent.

func SubscribedKafkaChannelReadiness

func SubscribedKafkaChannelReadiness(ctx context.Context, t *testing.T) *feature.Feature

SubscribedKafkaChannelReadiness returns a Feature testing if a subscribed KafkaChannel becomes ready.

func TestName

func TestName(ctx context.Context, t *testing.T) string

TestName returns the name of the Test associated with the Context for the test.

func UnsubscribedKafkaChannelReadiness

func UnsubscribedKafkaChannelReadiness(ctx context.Context, t *testing.T) *feature.Feature

UnsubscribedKafkaChannelReadiness returns a Feature testing if an unsubscribed KafkaChannel becomes ready.

Types

This section is empty.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL