features

Documentation

Index

• func BrokerAuthSecretDoesNotExist() *feature.Feature
• func BrokerAuthSecretForInternalTopicDoesNotExist() *feature.Feature
• func BrokerCannotReachKafkaCluster() *feature.Feature
• func BrokerConfigMapDeletedFirst() *feature.Feature
• func BrokerConfigMapDoesNotExist() *feature.Feature
• func BrokerConfigmapCreated(configName string) *feature.Feature
• func BrokerDeletedRecreated() *feature.Feature
• func BrokerExternalTopicAuthSecretDoesNotExist() *feature.Feature
• func BrokerExternalTopicDoesNotExist() *feature.Feature
• func BrokerWithBogusConfig() *feature.Feature
• func CleanupNamespace(name string) *feature.Feature
• func CreateSecretsAfterKafkaSource() *feature.Feature
• func KafkaChannelLease() *feature.Feature
• func KafkaSourceInitialOffsetEarliest(count int, topic string) *feature.Feature
• func KafkaSourceLease() *feature.Feature
• func KafkaSourcesAreNotPresentInContractConfigMaps(prefix string) *feature.Feature
• func NamespacedBrokerResourcesPropagation() *feature.Feature
• func ScaleKafkaSource() *feature.Feature
• func SetupAndCleanupKafkaSources(prefix string, n int) *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
• type ResourceError
  • func (r ResourceError) Error() string

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 KafkaSourceInitialOffsetEarliest

func KafkaSourceInitialOffsetEarliest(count int, topic string) *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 SetupKafkaTopicWithEvents

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