kafkachannel

Documentation

Index

• Constants
• func ConfigureDataPlane(ctx context.Context, t *testing.T) *feature.Feature
• func ReceiverName(ctx context.Context, t *testing.T) string
• func SendEvents(ctx context.Context, t *testing.T, eventCount int, startId int, endId int) *feature.Feature
• func SenderName(ctx context.Context, t *testing.T) string
• func SenderSink(ctx context.Context, t *testing.T) string
• func SubscribedKafkaChannelReadiness(ctx context.Context, t *testing.T) *feature.Feature
• func TestName(ctx context.Context, t *testing.T) string
• func UnsubscribedKafkaChannelReadiness(ctx context.Context, t *testing.T) *feature.Feature

Constants

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

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.