features

package
v0.38.4 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 15, 2023 License: Apache-2.0 Imports: 49 Imported by: 0

Documentation

Index

Constants

View Source
const (
	SASLSecretName = "strimzi-sasl-secret"
	TLSSecretName  = "strimzi-tls-secret"
	SASLMech       = "sasl"
	TLSMech        = "tls"
	PlainMech      = "plain"
)

Variables

This section is empty.

Functions

func BrokerAuthSecretDoesNotExist

func BrokerAuthSecretDoesNotExist() *feature.Feature

BrokerAuthSecretDoesNotExist tests that a broker can be deleted without the Secret existing.

func BrokerAuthSecretForInternalTopicDoesNotExist

func BrokerAuthSecretForInternalTopicDoesNotExist() *feature.Feature

BrokerAuthSecretForInternalTopicDoesNotExist tests that a broker can be deleted without the Secret.

func BrokerCannotReachKafkaCluster

func BrokerCannotReachKafkaCluster() *feature.Feature

BrokerCannotReachKafkaCluster tests that a broker can be deleted even when KafkaCluster is unreachable.

func BrokerConfigMapDeletedFirst

func BrokerConfigMapDeletedFirst() *feature.Feature

func BrokerConfigMapDoesNotExist

func BrokerConfigMapDoesNotExist() *feature.Feature

BrokerConfigMapDoesNotExist tests that a broker can be deleted without the ConfigMap existing.

func BrokerDeletedRecreated

func BrokerDeletedRecreated() *feature.Feature

func BrokerExternalTopicAuthSecretDoesNotExist

func BrokerExternalTopicAuthSecretDoesNotExist() *feature.Feature

BrokerExternalTopicAuthSecretDoesNotExist tests that a broker can be deleted without the Secret and Topic existing.

func BrokerExternalTopicDoesNotExist

func BrokerExternalTopicDoesNotExist() *feature.Feature

BrokerExternalTopicDoesNotExist tests that a broker can be deleted without the Topic existing.

func BrokerNotReadyWithoutAuthSecret added in v0.37.0

func BrokerNotReadyWithoutAuthSecret() *feature.Feature

func BrokerWithBogusConfig

func BrokerWithBogusConfig() *feature.Feature

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 CleanupNamespace(name string) *feature.Feature

func CreateSecretsAfterKafkaSource

func CreateSecretsAfterKafkaSource() *feature.Feature

func KafkaChannelLease

func KafkaChannelLease() *feature.Feature

func KafkaSourceBinaryEvent added in v0.37.1

func KafkaSourceBinaryEvent() *feature.Feature

func KafkaSourceInitialOffsetEarliest added in v0.36.2

func KafkaSourceInitialOffsetEarliest(count int, topic string) *feature.Feature

func KafkaSourceLease

func KafkaSourceLease() *feature.Feature

func KafkaSourceSASL added in v0.37.1

func KafkaSourceSASL() *feature.Feature

func KafkaSourceStructuredEvent added in v0.37.1

func KafkaSourceStructuredEvent() *feature.Feature

func KafkaSourceTLS added in v0.37.1

func KafkaSourceTLS(kafkaSource, kafkaSink, topic string) *feature.Feature

func KafkaSourceWithEventAfterUpdate added in v0.37.1

func KafkaSourceWithEventAfterUpdate(kafkaSource, kafkaSink, topic string) *feature.Feature

func KafkaSourceWithExtensions added in v0.37.1

func KafkaSourceWithExtensions() *feature.Feature

func KafkaSourcesAreNotPresentInContractConfigMaps

func KafkaSourcesAreNotPresentInContractConfigMaps(prefix string) *feature.Feature

func NamespacedBrokerResourcesPropagation

func NamespacedBrokerResourcesPropagation() *feature.Feature

func ScaleKafkaSource

func ScaleKafkaSource() *feature.Feature

func SetupAndCleanupKafkaSources

func SetupAndCleanupKafkaSources(prefix string, n int) *feature.Feature

func SetupBrokerAuth added in v0.37.0

func SetupBrokerAuth(bootstrapServer string, authSecretOptions ...manifest.CfgFn) *feature.Feature

func SetupBrokerAuthPlaintext added in v0.37.0

func SetupBrokerAuthPlaintext() *feature.Feature

func SetupBrokerAuthSaslPlaintextScram512 added in v0.37.0

func SetupBrokerAuthSaslPlaintextScram512(ctx context.Context) *feature.Feature

func SetupBrokerAuthSsl added in v0.37.0

func SetupBrokerAuthSsl(ctx context.Context) *feature.Feature

func SetupBrokerAuthSslSaslScram512 added in v0.37.0

func SetupBrokerAuthSslSaslScram512(ctx context.Context) *feature.Feature

func SetupKafkaSources

func SetupKafkaSources(prefix string, n int) *feature.Feature

func SetupKafkaTopicWithEvents added in v0.36.2

func SetupKafkaTopicWithEvents(count int, topic string) *feature.Feature

func SetupNamespace

func SetupNamespace(name string) *feature.Feature

func SetupNamespacedBroker

func SetupNamespacedBroker(name string) *feature.Feature

func TriggerLatestOffset

func TriggerLatestOffset() *feature.Feature

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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL