kafkasource

package
v0.40.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 26, 2024 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GVR

func Install

func Install(name string, opts ...manifest.CfgFn) feature.StepFn

Install will create a KafkaSource resource, using the latest version, augmented with the config fn options.

func IsReady

func IsReady(name string, timings ...time.Duration) feature.StepFn

IsReady tests to see if a KafkaSource becomes ready within the time given.

func VerifyScale

func VerifyScale(name string, replicas int32) feature.StepFn

func WithAnnotations

func WithAnnotations(annotations map[string]string) manifest.CfgFn

WithAnnotations adds annotation to a KafkaSource metadata.

func WithBootstrapServers

func WithBootstrapServers(bootstrapServers []string) manifest.CfgFn

WithBootstrapServers adds the bootstrapServers config to a KafkaSource spec.

func WithConsumers

func WithConsumers(consumers int32) manifest.CfgFn

WithConsumers adds consumers to a KafkaSource spec.

func WithExtensions

func WithExtensions(extensions map[string]string) manifest.CfgFn

WithExtensions set ceoverrides.extensions to a KafkaSource spec.

func WithInitialOffset added in v0.36.2

func WithInitialOffset(offset sources.Offset) manifest.CfgFn

WithInitialOffset adds the initial offset config to a KafkaSource spec.

func WithOrdering added in v0.37.1

func WithOrdering(ordering string) manifest.CfgFn

WithOrdering adds ordering a KafkaSource spec.

func WithSASLDisabled added in v0.37.1

func WithSASLDisabled() manifest.CfgFn

WithSASLDisabled disables SASL to a KafkaSource spec.

func WithSASLEnabled

func WithSASLEnabled() manifest.CfgFn

WithSASLEnabled enables SASL to a KafkaSource spec.

func WithSASLPassword

func WithSASLPassword(name, key string) manifest.CfgFn

WithSASLPassword adds the SASL password config to a KafkaSource spec.

func WithSASLType

func WithSASLType(name, key string) manifest.CfgFn

WithSASLType adds the SASL type config to a KafkaSource spec.

func WithSASLUser

func WithSASLUser(name, key string) manifest.CfgFn

WithSASLUser adds the SASL user config to a KafkaSource spec.

func WithSink

func WithSink(d *duckv1.Destination) manifest.CfgFn

WithSink adds the sink related config to a KafkaSource spec.

func WithTLSCACert

func WithTLSCACert(name, key string) manifest.CfgFn

WithTLSCACert adds the TLS caCert config to a KafkaSource spec.

func WithTLSCert

func WithTLSCert(name, key string) manifest.CfgFn

WithTLSCert adds the TLS cert config to a KafkaSource spec.

func WithTLSDisabled added in v0.37.1

func WithTLSDisabled() manifest.CfgFn

WithTLSDisabled disables TLS to a KafkaSource spec.

func WithTLSEnabled

func WithTLSEnabled() manifest.CfgFn

WithTLSEnabled enables TLS to a KafkaSource spec.

func WithTLSKey

func WithTLSKey(name, key string) manifest.CfgFn

WithTLSKey adds the TLS key config to a KafkaSource spec.

func WithTopics

func WithTopics(topics []string) manifest.CfgFn

WithTopics adds the topics config to a KafkaSource spec.

func WithVersion

func WithVersion(version string) manifest.CfgFn

WithVersion overrides the default API version

Types

This section is empty.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL