continual

Documentation

Index

• Variables
• func CreateKafkaSender(ctx context.Context, log *zap.SugaredLogger) sender.EventSenderWithContext
• func SourceTest(opts SourceTestOptions) pkgupgrade.BackgroundOperation
• type KafkaCluster
• 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 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

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

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.