kafkasource

Documentation

Index

• func GVR() schema.GroupVersionResource
• func Install(name string, opts ...manifest.CfgFn) feature.StepFn
• func IsReady(name string, timings ...time.Duration) feature.StepFn
• func VerifyScale(name string, replicas int32) feature.StepFn
• func WithAnnotations(annotations map[string]string) manifest.CfgFn
• func WithBootstrapServers(bootstrapServers []string) manifest.CfgFn
• func WithConsumers(consumers int32) manifest.CfgFn
• func WithExtensions(extensions map[string]string) manifest.CfgFn
• func WithInitialOffset(offset sources.Offset) manifest.CfgFn
• func WithOrdering(ordering string) manifest.CfgFn
• func WithSASLDisabled() manifest.CfgFn
• func WithSASLEnabled() manifest.CfgFn
• func WithSASLPassword(name, key string) manifest.CfgFn
• func WithSASLType(name, key string) manifest.CfgFn
• func WithSASLUser(name, key string) manifest.CfgFn
• func WithSink(d *duckv1.Destination) manifest.CfgFn
• func WithTLSCACert(name, key string) manifest.CfgFn
• func WithTLSCert(name, key string) manifest.CfgFn
• func WithTLSDisabled() manifest.CfgFn
• func WithTLSEnabled() manifest.CfgFn
• func WithTLSKey(name, key string) manifest.CfgFn
• func WithTopics(topics []string) manifest.CfgFn
• func WithVersion(version string) manifest.CfgFn

Functions

func GVR

func GVR() schema.GroupVersionResource

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

func WithInitialOffset(offset sources.Offset) manifest.CfgFn

WithInitialOffset adds the initial offset config to a KafkaSource spec.

func WithOrdering

func WithOrdering(ordering string) manifest.CfgFn

WithOrdering adds ordering a KafkaSource spec.

func WithSASLDisabled

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

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