Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( // ErrIllegalEndpointFormat if given endpoint structure is illegal and can't // be used. ErrIllegalEndpointFormat = errors.New( "illegal format for Kafka topic endpoint") // ErrCantConnectToKafka if connection to kafka can't be established. ErrCantConnectToKafka = errors.New( "unable to connect to Kafka bootstrap servers") // ErrCantSend if event can't be sent to given Kafka topic ErrCantSend = errors.New("can't send event to kafka topic") )
Functions ¶
func CreateKafkaSender ¶
func CreateKafkaSender(ctx context.Context, log *zap.SugaredLogger) sender.EventSenderWithContext
CreateKafkaSender will create a wathola sender that sends events to Kafka topic directly.
func SourceTest ¶
func SourceTest(opts SourceTestOptions) pkgupgrade.BackgroundOperation
SourceTest tests source operation in continual manner during the whole upgrade and downgrade process asserting that all event are propagated well.
Types ¶
type KafkaCluster ¶
KafkaCluster represents Kafka cluster endpoint.
type SourceTestOptions ¶
type SourceTestOptions struct { *TestOptions *KafkaCluster }
SourceTestOptions holds test options for KafkaSource tests.
type TestOptions ¶
type TestOptions struct { prober.ContinualVerificationOptions SUTs map[string]sut.SystemUnderTest }
TestOptions holds options for EventingKafka continual tests.
Click to show internal directories.
Click to hide internal directories.