Documentation
¶
Index ¶
- func BrokerCannotReachKafkaCluster() *feature.Feature
- func BrokerConfigMapDeletedFirst() *feature.Feature
- func BrokerConfigMapDoesNotExist() *feature.Feature
- func BrokerDeletedRecreated() *feature.Feature
- func CreateSecretsAfterKafkaSource() *feature.Feature
- func KafkaChannelLease() *feature.Feature
- func KafkaSourceLease() *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 BrokerDeletedRecreated ¶
func CreateSecretsAfterKafkaSource ¶ added in v0.33.3
func KafkaChannelLease ¶ added in v0.31.0
func KafkaSourceLease ¶ added in v0.31.0
Types ¶
This section is empty.
Source Files
¶
Directories
Click to show internal directories.
Click to hide internal directories.