Documentation ¶
Index ¶
- Constants
- func BrokerAuthSecretDoesNotExist() *feature.Feature
- func BrokerAuthSecretForInternalTopicDoesNotExist() *feature.Feature
- func BrokerCannotReachKafkaCluster() *feature.Feature
- func BrokerConfigMapDeletedFirst() *feature.Feature
- func BrokerConfigMapDoesNotExist() *feature.Feature
- func BrokerDeletedRecreated() *feature.Feature
- func BrokerExternalTopicAuthSecretDoesNotExist() *feature.Feature
- func BrokerExternalTopicDoesNotExist() *feature.Feature
- func BrokerNotReadyWithoutAuthSecret() *feature.Feature
- func BrokerWithBogusConfig() *feature.Feature
- func BrokerWithCustomReplicationFactorAndNumPartitions(env environment.Environment) *feature.Feature
- func BrokerWithTriggersAndKafkaSink(env environment.Environment) *feature.Feature
- func CleanupNamespace(name string) *feature.Feature
- func CreateSecretsAfterKafkaSource() *feature.Feature
- func KafkaChannelLease() *feature.Feature
- func KafkaSourceBinaryEvent() *feature.Feature
- func KafkaSourceBinaryEventWithExtensions() *feature.Feature
- func KafkaSourceInitialOffsetEarliest(count int, topic string) *feature.Feature
- func KafkaSourceLease() *feature.Feature
- func KafkaSourceSASL() *feature.Feature
- func KafkaSourceScalesToZeroWithKeda() *feature.Feature
- func KafkaSourceStructuredEvent() *feature.Feature
- func KafkaSourceTLS(kafkaSource, kafkaSink, topic string) *feature.Feature
- func KafkaSourceTLSSink() *feature.Feature
- func KafkaSourceTLSSinkTrustBundle() *feature.Feature
- func KafkaSourceWithEventAfterUpdate(kafkaSource, kafkaSink, topic string) *feature.Feature
- func KafkaSourceWithExtensions() *feature.Feature
- func KafkaSourcesAreNotPresentInContractConfigMaps(prefix string) *feature.Feature
- func KnativeKafkaCEExtensionsAdded() *feature.FeatureSet
- func NamespacedBrokerResourcesPropagation() *feature.Feature
- func RotateBrokerTLSCertificates() *feature.Feature
- func RotateChannelTLSCertificates() *feature.Feature
- func RotateSinkTLSCertificates(ctx context.Context) *feature.Feature
- func ScaleKafkaSource() *feature.Feature
- func SetupAndCleanupKafkaSources(prefix string, n int) *feature.Feature
- func SetupBrokerAuth(bootstrapServer string, authSecretOptions ...manifest.CfgFn) *feature.Feature
- func SetupBrokerAuthPlaintext() *feature.Feature
- func SetupBrokerAuthRestrictedSslSaslScram512(ctx context.Context) *feature.Feature
- func SetupBrokerAuthSaslPlaintextScram512(ctx context.Context) *feature.Feature
- func SetupBrokerAuthSsl(ctx context.Context) *feature.Feature
- func SetupBrokerAuthSslSaslScram512(ctx context.Context) *feature.Feature
- func SetupBrokerNoAuthSsl(ctx context.Context) *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
- func TriggerUsesConsumerGroupIDTemplate() *feature.Feature
- type ResourceError
Constants ¶
const ( SASLSecretName = "strimzi-sasl-secret" TLSSecretName = "strimzi-tls-secret" SASLMech = "sasl" TLSMech = "tls" PlainMech = "plain" )
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 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 BrokerNotReadyWithoutAuthSecret ¶ added in v0.37.0
func BrokerWithBogusConfig ¶
BrokerWithBogusConfig tests that a broker can be deleted even when it has a bogus config attached.
func BrokerWithCustomReplicationFactorAndNumPartitions ¶ added in v0.37.0
func BrokerWithCustomReplicationFactorAndNumPartitions(env environment.Environment) *feature.Feature
func BrokerWithTriggersAndKafkaSink ¶ added in v0.37.0
func BrokerWithTriggersAndKafkaSink(env environment.Environment) *feature.Feature
+---------+ +--------+ +---------+ +---------------------------+ | Broker +---->+ Trigger+---->+KafkaSink+-->+kafka consumer (test image)| +----+----+ +--------+ +----+----+ +---------------------------+
| ^ | +--------+ | +--------->+ Trigger+----------+ +--------+
func CleanupNamespace ¶
func KafkaChannelLease ¶
func KafkaSourceBinaryEvent ¶ added in v0.37.1
func KafkaSourceBinaryEventWithExtensions ¶ added in v0.39.4
func KafkaSourceInitialOffsetEarliest ¶ added in v0.36.2
func KafkaSourceLease ¶
func KafkaSourceSASL ¶ added in v0.37.1
func KafkaSourceScalesToZeroWithKeda ¶ added in v0.39.3
func KafkaSourceStructuredEvent ¶ added in v0.37.1
func KafkaSourceTLS ¶ added in v0.37.1
func KafkaSourceTLSSink ¶ added in v0.40.0
func KafkaSourceTLSSinkTrustBundle ¶ added in v0.40.0
func KafkaSourceWithEventAfterUpdate ¶ added in v0.37.1
func KafkaSourceWithExtensions ¶ added in v0.37.1
func KnativeKafkaCEExtensionsAdded ¶ added in v0.40.0
func KnativeKafkaCEExtensionsAdded() *feature.FeatureSet
func RotateBrokerTLSCertificates ¶ added in v0.38.9
func RotateChannelTLSCertificates ¶ added in v0.38.10
func RotateSinkTLSCertificates ¶ added in v0.38.10
func ScaleKafkaSource ¶
func SetupBrokerAuth ¶ added in v0.37.0
func SetupBrokerAuthPlaintext ¶ added in v0.37.0
func SetupBrokerAuthRestrictedSslSaslScram512 ¶ added in v0.40.7
func SetupBrokerAuthSaslPlaintextScram512 ¶ added in v0.37.0
func SetupBrokerAuthSsl ¶ added in v0.37.0
func SetupBrokerAuthSslSaslScram512 ¶ added in v0.37.0
func SetupBrokerNoAuthSsl ¶ added in v0.40.0
func SetupKafkaTopicWithEvents ¶ added in v0.36.2
func SetupNamespace ¶
func SetupNamespacedBroker ¶
func TriggerLatestOffset ¶
TriggerLatestOffset tests that a Trigger receives only new events.
func TriggerUsesConsumerGroupIDTemplate ¶ added in v0.40.8
Types ¶
type ResourceError ¶
type ResourceError struct { Resource *contract.Resource `json:"resource"` Sources *sources.KafkaSourceList `json:"sources"` }
func (ResourceError) Error ¶
func (r ResourceError) Error() string