client

Documentation

Index

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

Functions

func NewFakeKafkaSourceClient

func NewFakeKafkaSourceClient(ns string) types.KafkaSourceClient

NewFakeKafkaSourceClient is to create a fake KafkaSourceClient to test

func NewFakeKafkaSourceParams

func NewFakeKafkaSourceParams() *types.KafkaSourceParams

NewFakeKafkaSourceParams is to create a fake KafkaSourceParams to test

func NewKafkaSourceClient

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

NewKafkaSourceClient is to create a KafkaSourceClient

Types

type KafkaSourceBuilder

type KafkaSourceBuilder struct {
	// contains filtered or unexported fields
}

KafkaSourceBuilder is for building the source

func NewKafkaSourceBuilder

func NewKafkaSourceBuilder(name string) *KafkaSourceBuilder

NewKafkaSourceBuilder for building ApiServer source object

func NewKafkaSourceBuilderFromExisting

func NewKafkaSourceBuilderFromExisting(kSource *v1alpha1.KafkaSource) *KafkaSourceBuilder

NewKafkaSourceBuilderFromExisting for building the object from existing KafkaSource object

func (*KafkaSourceBuilder) BootstrapServers

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

BootstrapServers to set the value of BootstrapServers

func (*KafkaSourceBuilder) Build

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

Build the KafkaSource object

func (*KafkaSourceBuilder) ConsumerGroup

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

ConsumerGroup to set the value of ConsumerGroup

func (*KafkaSourceBuilder) Sink

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

Sink or destination of the source

func (*KafkaSourceBuilder) Topics

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

Topics to set the value of Topics