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

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.