client

Oct 18, 2022

Changes in this version

type KafkaSourceBuilder

+ func (b *KafkaSourceBuilder) Annotations(annotations map[string]string) *KafkaSourceBuilder

+ func (b *KafkaSourceBuilder) Labels(labels map[string]string) *KafkaSourceBuilder

Apr 7, 2021

Changes in this version

type KafkaSourceBuilder

+ func (b *KafkaSourceBuilder) CloudEventOverrides(ceo map[string]string, toRemove []string) *KafkaSourceBuilder

Dec 8, 2020

Changes in this version

+ func NewFakeKafkaSourceClient(ns string) types.KafkaSourceClient

+ func NewFakeKafkaSourceParams() *types.KafkaSourceParams

+ func NewKafkaSourceClient(kafkaParams *types.KafkaSourceParams, restConfig *rest.Config, ns string) (types.KafkaSourceClient, error)

+ type KafkaSourceBuilder struct

+ func NewKafkaSourceBuilder(name string) *KafkaSourceBuilder

+ func NewKafkaSourceBuilderFromExisting(kSource *v1alpha1.KafkaSource) *KafkaSourceBuilder

+ func (b *KafkaSourceBuilder) BootstrapServers(server string) *KafkaSourceBuilder

+ func (b *KafkaSourceBuilder) Build() *v1alpha1.KafkaSource

+ func (b *KafkaSourceBuilder) ConsumerGroup(consumerGroup string) *KafkaSourceBuilder

+ func (b *KafkaSourceBuilder) Sink(sink *duckv1.Destination) *KafkaSourceBuilder

+ func (b *KafkaSourceBuilder) Topics(topics string) *KafkaSourceBuilder