continual

Documentation

Index

• func BrokerTest(opts KafkaBrokerTestOptions) pkgupgrade.BackgroundOperation
• func SinkSourceTest(opts KafkaSinkSourceTestOptions) pkgupgrade.BackgroundOperation
• type Broker
• type KafkaBrokerTestOptions
• type KafkaSinkSourceTestOptions
• type Sink
• type Source
• 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.

func SinkSourceTest

func SinkSourceTest(opts KafkaSinkSourceTestOptions) pkgupgrade.BackgroundOperation

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 KafkaSinkSourceTestOptions

type KafkaSinkSourceTestOptions struct {
	*eventingkafkaupgrade.TestOptions
	*Sink
	*Source
}

type Sink

type Sink struct {
	Name string
	Spec eventing.KafkaSinkSpec
}

type Source

type Source struct {
	Name string
	Spec sources.KafkaSourceSpec
}

type TestOptions

type TestOptions struct {
	prober.ContinualVerificationOptions
}

TestOptions holds options for EventingKafka continual tests.

type Triggers

type Triggers struct {
	Prefix string
	sut.Triggers
}