helpers

Documentation

Index

• Constants
• Variables
• func AssureKafkaSourceConsumesMsgNoEvent(t *testing.T)
• func MustCreateTopic(client *testlib.Client, clusterName, clusterNamespace, topicName string, ...)
• func MustPublishKafkaMessage(client *testlib.Client, bootstrapServer string, topic string, key string, ...)
• func WaitForKafkaResourceReady(ctx context.Context, client *testlib.Client, namespace, name string, ...) error
• type SourceTestScope

Constants

const (
	KafkaBootstrapUrlPlain = "my-cluster-kafka-bootstrap.kafka.svc:9092"
	KafkaClusterName       = "my-cluster"
	KafkaClusterNamespace  = "kafka"
)

Variables

var (
	ImcGVR = schema.GroupVersionResource{Group: "messaging.knative.dev", Version: "v1", Resource: "inmemorychannels"}
)

Functions

func AssureKafkaSourceConsumesMsgNoEvent

func AssureKafkaSourceConsumesMsgNoEvent(t *testing.T)

AssureKafkaSourceConsumesMsgNoEvent assures that KafkaSource reads messages that were not cloud events.

func MustCreateTopic

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

func MustPublishKafkaMessage

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

func WaitForKafkaResourceReady

func WaitForKafkaResourceReady(ctx context.Context, client *testlib.Client, namespace, name string, gvr schema.GroupVersionResource) error

Types

type SourceTestScope

type SourceTestScope func(auth, testCase, version string) bool

SourceTestScope returns true if we should proceed with given test case.