helpers

Documentation

Index

• Variables
• func CheckKafkaSourceState(ctx context.Context, c *testlib.Client, name string, ...) error
• func CheckRADeployment(ctx context.Context, c *testlib.Client, name string, ...) error
• 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, ...)

Variables

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

Functions

func CheckKafkaSourceState

func CheckKafkaSourceState(ctx context.Context, c *testlib.Client, name string, inState func(ks *sourcesv1beta1.KafkaSource) (bool, error)) error

CheckKafkaSourceState waits for specified kafka source resource state On timeout reports error

func CheckRADeployment

func CheckRADeployment(ctx context.Context, c *testlib.Client, name string, inState func(deps *appsv1.DeploymentList) (bool, error)) error

CheckRADeployment waits for desired state of receiver adapter On timeout reports error

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)