continual

Documentation

Index

• func BrokerBackedByChannelTest(opts ChannelTestOptions) pkgupgrade.BackgroundOperation
• func BrokerTest(opts KafkaBrokerTestOptions) pkgupgrade.BackgroundOperation
• func ChannelTest(opts ChannelTestOptions) pkgupgrade.BackgroundOperation
• func SinkSourceTest(opts KafkaSinkSourceTestOptions) pkgupgrade.BackgroundOperation
• type Broker
• type ChannelTestOptions
• type KafkaBrokerTestOptions
• type KafkaSinkSourceTestOptions
• type ReplicationOptions
• type RetryOptions
• type Sink
• type Source
• type TestOptions
• type Triggers

Functions

func BrokerBackedByChannelTest

func BrokerBackedByChannelTest(opts ChannelTestOptions) pkgupgrade.BackgroundOperation

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

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 ChannelTest

func ChannelTest(opts ChannelTestOptions) pkgupgrade.BackgroundOperation

ChannelTest tests channel 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
	Class string
	*ReplicationOptions
	*RetryOptions
}

type ChannelTestOptions

type ChannelTestOptions struct {
	*TestOptions
	*ReplicationOptions
	*RetryOptions
	*metav1.TypeMeta
}

ChannelTestOptions holds test options for KafkaChannel tests.

type KafkaBrokerTestOptions

type KafkaBrokerTestOptions struct {
	*TestOptions
	*Broker
	*Triggers
}

KafkaBrokerTestOptions holds test options for Kafka Broker tests.

type KafkaSinkSourceTestOptions

type KafkaSinkSourceTestOptions struct {
	*TestOptions
	*Sink
	*Source
}

type ReplicationOptions

type ReplicationOptions struct {
	NumPartitions     int
	ReplicationFactor int
}

ReplicationOptions hold options for replication.

type RetryOptions

type RetryOptions struct {
	RetryCount    int
	BackoffPolicy eventingduckv1.BackoffPolicyType
	BackoffDelay  string
}

RetryOptions holds options for retries.

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
	SUTs map[string]sut.SystemUnderTest
}

TestOptions holds options for EventingKafka continual tests.

type Triggers

type Triggers struct {
	Prefix string
	sut.Triggers
}