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, ...)
Constants ¶
This section is empty.
Variables ¶
View Source
var (
ImcGVR = schema.GroupVersionResource{Group: "messaging.knative.dev", Version: "v1beta1", Resource: "inmemorychannels"}
)
Functions ¶
func CheckKafkaSourceState ¶ added in v0.18.0
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 ¶ added in v0.18.0
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 MustPublishKafkaMessage ¶
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.