helpers

package
v0.39.2 Latest Latest
Warning

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

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

Documentation

Index

Constants

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

Variables

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

Functions

func AssureKafkaSourceConsumesMsgNoEvent added in v0.37.1

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.

Jump to

Keyboard shortcuts

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