continual

Documentation

Index

• Variables
• func BrokerBackedByChannelTest(opts ChannelTestOptions) pkgupgrade.BackgroundOperation
• func ChannelTest(opts ChannelTestOptions) pkgupgrade.BackgroundOperation
• func CreateKafkaSender(ctx context.Context, log *zap.SugaredLogger) sender.EventSender
• func SourceTest(opts SourceTestOptions) pkgupgrade.BackgroundOperation
• type ChannelTestOptions
• type KafkaCluster
• type ReplicationOptions
• type RetryOptions
• type SourceTestOptions
• type TestOptions

Variables

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 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 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 CreateKafkaSender

func CreateKafkaSender(ctx context.Context, log *zap.SugaredLogger) sender.EventSender

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 ChannelTestOptions

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

ChannelTestOptions holds test options for KafkaChannel tests.

type KafkaCluster

type KafkaCluster struct {
	BootstrapServers []string
	Name             string
	Namespace        string
}

KafkaCluster represents Kafka cluster endpoint.

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 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.