helpers

Documentation

Index

• func MustCreateTopic(client *testlib.Client, clusterName string, clusterNamespace string, ...)
• func MustPublishKafkaMessage(client *testlib.Client, bootstrapServer string, topic string, key string, ...)
• func MustPublishKafkaMessageViaBinding(client *testlib.Client, selector map[string]string, topic string, key string, ...)

Functions

func MustCreateTopic

func MustCreateTopic(client *testlib.Client, clusterName string, clusterNamespace string, topicName string)

func MustPublishKafkaMessage

func MustPublishKafkaMessage(client *testlib.Client, bootstrapServer string, topic string, key string, headers map[string]string, value string)

func MustPublishKafkaMessageViaBinding

func MustPublishKafkaMessageViaBinding(client *testlib.Client, selector map[string]string, topic string, key string, headers map[string]string, value string)