features

package
v0.36.1 Latest Latest
Warning

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

Go to latest
Published: Feb 17, 2023 License: Apache-2.0 Imports: 39 Imported by: 0

Documentation

Index

Constants

This section is empty.

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 BrokerConfigmapCreated

func BrokerConfigmapCreated(configName string) *feature.Feature

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 BrokerWithBogusConfig

func BrokerWithBogusConfig() *feature.Feature

BrokerWithBogusConfig tests that a broker can be deleted even when it has a bogus config attached.

func CleanupNamespace

func CleanupNamespace(name string) *feature.Feature

func CreateSecretsAfterKafkaSource

func CreateSecretsAfterKafkaSource() *feature.Feature

func KafkaChannelLease

func KafkaChannelLease() *feature.Feature

func KafkaSourceLease

func KafkaSourceLease() *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 SetupKafkaSources

func SetupKafkaSources(prefix string, n int) *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