Documentation
¶
Index ¶
- func BrokerAuthSecretDoesNotExist() *feature.Feature
- func BrokerAuthSecretForInternalTopicDoesNotExist() *feature.Feature
- func BrokerCannotReachKafkaCluster() *feature.Feature
- func BrokerConfigMapDeletedFirst() *feature.Feature
- func BrokerConfigMapDoesNotExist() *feature.Feature
- func BrokerConfigmapCreated(configName string) *feature.Feature
- func BrokerDeletedRecreated() *feature.Feature
- func BrokerExternalTopicAuthSecretDoesNotExist() *feature.Feature
- func BrokerExternalTopicDoesNotExist() *feature.Feature
- func BrokerWithBogusConfig() *feature.Feature
- func CleanupNamespace(name string) *feature.Feature
- func CreateSecretsAfterKafkaSource() *feature.Feature
- func KafkaChannelLease() *feature.Feature
- func KafkaSourceInitialOffsetEarliest(count int, topic string) *feature.Feature
- func KafkaSourceLease() *feature.Feature
- func KafkaSourcesAreNotPresentInContractConfigMaps(prefix string) *feature.Feature
- func NamespacedBrokerResourcesPropagation() *feature.Feature
- func ScaleKafkaSource() *feature.Feature
- func SetupAndCleanupKafkaSources(prefix string, n int) *feature.Feature
- func SetupKafkaSources(prefix string, n int) *feature.Feature
- func SetupKafkaTopicWithEvents(count int, topic string) *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 BrokerAuthSecretDoesNotExist ¶
BrokerAuthSecretDoesNotExist tests that a broker can be deleted without the Secret existing.
func BrokerAuthSecretForInternalTopicDoesNotExist ¶
BrokerAuthSecretForInternalTopicDoesNotExist tests that a broker can be deleted without the Secret.
func BrokerCannotReachKafkaCluster ¶
BrokerCannotReachKafkaCluster tests that a broker can be deleted even when KafkaCluster is unreachable.
func BrokerConfigMapDoesNotExist ¶
BrokerConfigMapDoesNotExist tests that a broker can be deleted without the ConfigMap existing.
func BrokerConfigmapCreated ¶
func BrokerDeletedRecreated ¶
func BrokerExternalTopicAuthSecretDoesNotExist ¶
BrokerExternalTopicAuthSecretDoesNotExist tests that a broker can be deleted without the Secret and Topic existing.
func BrokerExternalTopicDoesNotExist ¶
BrokerExternalTopicDoesNotExist tests that a broker can be deleted without the Topic existing.
func BrokerWithBogusConfig ¶
BrokerWithBogusConfig tests that a broker can be deleted even when it has a bogus config attached.
func CleanupNamespace ¶
func KafkaChannelLease ¶
func KafkaSourceInitialOffsetEarliest ¶ added in v0.36.2
func KafkaSourceLease ¶
func ScaleKafkaSource ¶
func SetupKafkaTopicWithEvents ¶ added in v0.36.2
func SetupNamespace ¶
func SetupNamespacedBroker ¶
func TriggerLatestOffset ¶
TriggerLatestOffset tests that a Trigger receives only new events.
Types ¶
type ResourceError ¶
type ResourceError struct {
Resource *contract.Resource `json:"resource"`
Sources *sources.KafkaSourceList `json:"sources"`
}
func (ResourceError) Error ¶
func (r ResourceError) Error() string
Source Files
Directories