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 CleanupNamespace(name string) *feature.Feature
- func CreateSecretsAfterKafkaSource() *feature.Feature
- func KafkaChannelLease() *feature.Feature
- func KafkaSourceLease() *feature.Feature
- func KafkaSourcesAreNotPresentInContractConfigMaps(prefix string) *feature.Feature
- func SetupAndCleanupKafkaSources(prefix string, n int) *feature.Feature
- func SetupKafkaSources(prefix string, n int) *feature.Feature
- func SetupNamespace(name string) *feature.Feature
- func SetupNamespacedBroker(name string) *feature.Feature
- func TriggerLatestOffset() *feature.Feature
- type ResourceError
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 CreateSecretsAfterKafkaSource ¶ added in v0.33.3
func KafkaSourcesAreNotPresentInContractConfigMaps ¶ added in v0.35.6
func SetupAndCleanupKafkaSources ¶ added in v0.35.6
func SetupKafkaSources ¶ added in v0.35.6
func SetupNamespacedBroker ¶ added in v0.35.6
Types ¶
type ResourceError ¶ added in v0.35.6
type ResourceError struct { Resource *contract.Resource `json:"resource"` Sources *sources.KafkaSourceList `json:"sources"` }
func (ResourceError) Error ¶ added in v0.35.6
func (r ResourceError) Error() string
Source Files ¶
Click to show internal directories.
Click to hide internal directories.