helpers

Documentation

Index

• Variables
• func ChannelSubscriptionScaleReadyHelper(ctx context.Context, t *testing.T, ...)
• 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, clusterNamespace, topicName 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: "v1", Resource: "inmemorychannels"}
)

Functions

func ChannelSubscriptionScaleReadyHelper

func ChannelSubscriptionScaleReadyHelper(
	ctx context.Context,
	t *testing.T,
	channelTestRunner testlib.ComponentsTestRunner,
	options ...testlib.SetupClientOption)

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, 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 MustPublishKafkaMessageViaBinding

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