kafkachannel

Documentation

Index

• Constants
• func ConfigureDataPlane(ctx context.Context, t *testing.T) *feature.Feature
• func ReceiverName(ctx context.Context, t *testing.T) string
• func ReplayEvents(ctx context.Context, t *testing.T, offsetTime string, eventCount int, ...) *feature.Feature
• 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 ReplayEvents

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

ReplayEvents creates a Feature which adjusts a KafkaChannel Subscription to a specific offset time by creating a ResetOffset and verifying the expected final event count. The actual count is dependent upon the number of events in the KafkaChannel (Topic) related to the specified offsetTime.

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.