features

package
v0.44.0 Latest Latest
Warning

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

 Go to latest Published: Jan 27, 2025 License: Apache-2.0 Imports: 69 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

BrokerDeletedRecreated tests that when a broker and trigger is deleted and re-created, the original sink will eventually stop receiving events

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 ChannelScalesToZeroWithKeda added in v0.42.0 

func ChannelScalesToZeroWithKeda() *feature.Feature

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 KafkaSourceBinaryEventFeatureSetup added in v0.43.0 

func KafkaSourceBinaryEventFeatureSetup(f *feature.Feature) (string, string)

func KafkaSourceBinaryEventWithExtensions added in v0.39.4 

func KafkaSourceBinaryEventWithExtensions() *feature.Feature

func KafkaSourceFeatureAssert added in v0.43.0 

func KafkaSourceFeatureAssert(f *feature.Feature, kafkaSink, receiver string, customizeFunc CustomizeEventFunc)

func KafkaSourceFeatureSetup added in v0.43.0 

func KafkaSourceFeatureSetup(f *feature.Feature,
	kafkaSourceCfg kafkaSourceConfig,
	kafkaSinkCfg kafkaSinkConfig) (string, string)

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 KafkaSourceScaledObjectHasNoEmptyAuthRef added in v0.41.6 

func KafkaSourceScaledObjectHasNoEmptyAuthRef() *feature.Feature

func KafkaSourceScalesToZeroWithKeda added in v0.39.3 

func KafkaSourceScalesToZeroWithKeda() *feature.Feature

func KafkaSourceStructuredEvent added in v0.37.1 

func KafkaSourceStructuredEvent() *feature.Feature

func KafkaSourceStructuredEventFeatureSetup added in v0.43.0 

func KafkaSourceStructuredEventFeatureSetup(f *feature.Feature) (string, string)

func KafkaSourceTLS added in v0.37.1 

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

func KafkaSourceTLSSink added in v0.40.0 

func KafkaSourceTLSSink() *feature.Feature

func KafkaSourceTLSSinkTrustBundle added in v0.40.0 

func KafkaSourceTLSSinkTrustBundle() *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 KnativeKafkaCEExtensionsAdded added in v0.40.0 

func KnativeKafkaCEExtensionsAdded() *feature.FeatureSet

func NamespacedBrokerResourcesPropagation 

func NamespacedBrokerResourcesPropagation() *feature.Feature

func RotateBrokerTLSCertificates added in v0.38.9 

func RotateBrokerTLSCertificates() *feature.Feature

func RotateChannelTLSCertificates added in v0.38.10 

func RotateChannelTLSCertificates() *feature.Feature

func RotateSinkTLSCertificates added in v0.38.10 

func RotateSinkTLSCertificates(ctx context.Context) *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 SetupBrokerAuthRestrictedSslSaslScram512 added in v0.40.7 

func SetupBrokerAuthRestrictedSslSaslScram512(ctx context.Context) *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 SetupBrokerNoAuthSsl added in v0.40.0 

func SetupBrokerNoAuthSsl(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.

func TriggerScalesToZeroWithKeda added in v0.41.0 

func TriggerScalesToZeroWithKeda() *feature.Feature

func TriggerUsesConsumerGroupIDTemplate added in v0.40.8 

func TriggerUsesConsumerGroupIDTemplate() *feature.Feature

Types

type CustomizeEventFunc added in v0.43.0 

type CustomizeEventFunc func() ([]eventshub.EventsHubOption, EventMatcher)

CustomizeEventFunc creates a pair of eventshub options that customize the event and corresponding event matcher that will match the respective event.

func KafkaSourceBinaryEventCustomizeFunc added in v0.43.0 

func KafkaSourceBinaryEventCustomizeFunc() CustomizeEventFunc

func KafkaSourceStructuredEventCustomizeFunc added in v0.43.0 

func KafkaSourceStructuredEventCustomizeFunc() CustomizeEventFunc

type ResourceError 

type ResourceError struct {
	Resource *contract.Resource       `json:"resource"`
	Sources  *sources.KafkaSourceList `json:"sources"`
}

func (ResourceError) Error 

func (r ResourceError) Error() string

type SequenceAssertionBuilder added in v0.44.0 

type SequenceAssertionBuilder struct {
	// contains filtered or unexported fields
}

func EventSequenceOnStores added in v0.44.0 

func EventSequenceOnStores(names ...string) SequenceAssertionBuilder

EventSequenceOnStores starts an assertion about sequence of events received by the given named stores The assertions are specially designed for checking sequences as generated by sources with eventshub.AddSequence

func (SequenceAssertionBuilder) ContainsOnly added in v0.44.0 

func (b SequenceAssertionBuilder) ContainsOnly(matcher eventshub.EventInfoMatcher) SequenceAssertionBuilder

func (SequenceAssertionBuilder) ContainsOnlyEventsObservedBy added in v0.44.0 

func (b SequenceAssertionBuilder) ContainsOnlyEventsObservedBy(observerName string) SequenceAssertionBuilder

func (SequenceAssertionBuilder) Eventually added in v0.44.0 

func (b SequenceAssertionBuilder) Eventually() feature.StepFn

func (SequenceAssertionBuilder) FirstN added in v0.44.0 

func (b SequenceAssertionBuilder) FirstN(n int) SequenceAssertionBuilder

func (SequenceAssertionBuilder) IsAnUninterruptedSourceSequence added in v0.44.0 

func (b SequenceAssertionBuilder) IsAnUninterruptedSourceSequence() SequenceAssertionBuilder

func (SequenceAssertionBuilder) LastN added in v0.44.0 

func (b SequenceAssertionBuilder) LastN(n int) SequenceAssertionBuilder

func (SequenceAssertionBuilder) MatchingReceived added in v0.44.0 

func (b SequenceAssertionBuilder) MatchingReceived(matchers ...cetest.EventMatcher) SequenceAssertionBuilder

func (SequenceAssertionBuilder) OrderedBySourceSequence added in v0.44.0 

func (b SequenceAssertionBuilder) OrderedBySourceSequence() SequenceAssertionBuilder

func (SequenceAssertionBuilder) Reversed added in v0.44.0 

func (b SequenceAssertionBuilder) Reversed() SequenceAssertionBuilder

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.