features

Jan 16, 2023

Changes in this version

+ func CleanupNamespace(name string) *feature.Feature

+ func KafkaSourcesAreNotPresentInContractConfigMaps(prefix string) *feature.Feature

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

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

+ func SetupNamespace(name string) *feature.Feature

+ func SetupNamespacedBroker(name string) *feature.Feature

+ type ResourceError struct

+ Resource *contract.Resource

+ Sources *sources.KafkaSourceList

+ func (r ResourceError) Error() string

Oct 19, 2022

Changes in this version

+ func BrokerConfigmapCreated(configName string) *feature.Feature

+ func TriggerLatestOffset() *feature.Feature

Sep 19, 2022

Changes in this version

+ func BrokerCannotReachKafkaCluster() *feature.Feature

+ func BrokerConfigMapDoesNotExist() *feature.Feature

Aug 16, 2022

Changes in this version

+ func CreateSecretsAfterKafkaSource() *feature.Feature

Apr 20, 2022

Changes in this version

+ func KafkaChannelLease() *feature.Feature

+ func KafkaSourceLease() *feature.Feature

Dec 14, 2021

Changes in this version

+ func BrokerConfigMapDeletedFirst() *feature.Feature

+ func BrokerDeletedRecreated() *feature.Feature