continual

Documentation

Index

• func BrokerTest(opts KafkaBrokerTestOptions) pkgupgrade.BackgroundOperation
• type Broker
• type KafkaBrokerTestOptions
• type TestOptions
• type Triggers

Functions

func BrokerTest

func BrokerTest(opts KafkaBrokerTestOptions) pkgupgrade.BackgroundOperation

BrokerTest tests a broker operation in continual manner during the whole upgrade and downgrade process asserting that all event are propagated well.

Types

type Broker

type Broker struct {
	Name string
	*eventingkafkaupgrade.ReplicationOptions
	*eventingkafkaupgrade.RetryOptions
}

type KafkaBrokerTestOptions

type KafkaBrokerTestOptions struct {
	*eventingkafkaupgrade.TestOptions
	*Broker
	*Triggers
}

KafkaBrokerTestOptions holds test options for Kafka Broker tests.

type TestOptions

type TestOptions struct {
	prober.ContinualVerificationOptions
}

TestOptions holds options for EventingKafka continual tests.

type Triggers

type Triggers struct {
	Prefix string
	sut.Triggers
}