features

package
v0.35.10 Latest Latest
Warning

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

Go to latest
Published: Apr 3, 2023 License: Apache-2.0 Imports: 36 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func BrokerCannotReachKafkaCluster added in v0.33.7

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

func BrokerConfigMapDoesNotExist() *feature.Feature

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

func BrokerConfigmapCreated added in v0.35.0

func BrokerConfigmapCreated(configName string) *feature.Feature

func BrokerDeletedRecreated

func BrokerDeletedRecreated() *feature.Feature

func CleanupNamespace added in v0.35.6

func CleanupNamespace(name string) *feature.Feature

func CreateSecretsAfterKafkaSource added in v0.33.3

func CreateSecretsAfterKafkaSource() *feature.Feature

func KafkaChannelLease added in v0.31.0

func KafkaChannelLease() *feature.Feature

func KafkaSourceLease added in v0.31.0

func KafkaSourceLease() *feature.Feature

func KafkaSourcesAreNotPresentInContractConfigMaps added in v0.35.6

func KafkaSourcesAreNotPresentInContractConfigMaps(prefix string) *feature.Feature

func SetupAndCleanupKafkaSources added in v0.35.6

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

func SetupKafkaSources added in v0.35.6

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

func SetupNamespace added in v0.35.6

func SetupNamespace(name string) *feature.Feature

func SetupNamespacedBroker added in v0.35.6

func SetupNamespacedBroker(name string) *feature.Feature

func TriggerLatestOffset added in v0.35.0

func TriggerLatestOffset() *feature.Feature

TriggerLatestOffset tests that a Trigger receives only new events.

Types

type ResourceError added in v0.35.6

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

func (ResourceError) Error added in v0.35.6

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