Documentation
¶
Index ¶
- func BrokerCannotReachKafkaCluster() *feature.Feature
- func BrokerConfigMapDeletedFirst() *feature.Feature
- func BrokerConfigMapDoesNotExist() *feature.Feature
- func BrokerConfigmapCreated(configName string) *feature.Feature
- func BrokerDeletedRecreated() *feature.Feature
- func CreateSecretsAfterKafkaSource() *feature.Feature
- func KafkaChannelLease() *feature.Feature
- func KafkaSourceLease() *feature.Feature
- func TriggerLatestOffset() *feature.Feature
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func BrokerCannotReachKafkaCluster ¶ added in v0.33.7
BrokerCannotReachKafkaCluster tests that a broker can be deleted even when KafkaCluster is unreachable.
func BrokerConfigMapDoesNotExist ¶ added in v0.33.7
BrokerConfigMapDoesNotExist tests that a broker can be deleted without the ConfigMap existing.
func BrokerConfigmapCreated ¶ added in v0.35.0
func BrokerDeletedRecreated ¶
func CreateSecretsAfterKafkaSource ¶ added in v0.33.3
func KafkaChannelLease ¶ added in v0.31.0
func KafkaSourceLease ¶ added in v0.31.0
func TriggerLatestOffset ¶ added in v0.35.0
TriggerLatestOffset tests that a Trigger receives only new events.
Types ¶
This section is empty.
Source Files
¶
Directories
Click to show internal directories.
Click to hide internal directories.