client

Documentation

Index

• func NewFakeKafkaSourceClient(fakeClientTest *fake.FakeSourcesV1beta1, 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 *v1beta1.KafkaSource) *KafkaSourceBuilder
  • func (b *KafkaSourceBuilder) Annotations(annotations map[string]string) *KafkaSourceBuilder
  • func (b *KafkaSourceBuilder) BootstrapServers(servers []string) *KafkaSourceBuilder
  • func (b *KafkaSourceBuilder) Build() *v1beta1.KafkaSource
  • func (b *KafkaSourceBuilder) CloudEventOverrides(ceo map[string]string, toRemove []string) *KafkaSourceBuilder
  • func (b *KafkaSourceBuilder) ConsumerGroup(consumerGroup string) *KafkaSourceBuilder
  • func (b *KafkaSourceBuilder) Labels(labels map[string]string) *KafkaSourceBuilder
  • func (b *KafkaSourceBuilder) Sink(sink *duckv1.Destination) *KafkaSourceBuilder
  • func (b *KafkaSourceBuilder) Topics(topics []string) *KafkaSourceBuilder

Functions

func NewFakeKafkaSourceClient

func NewFakeKafkaSourceClient(fakeClientTest *fake.FakeSourcesV1beta1, 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 *v1beta1.KafkaSource) *KafkaSourceBuilder

NewKafkaSourceBuilderFromExisting for building the object from existing KafkaSource object

func (*KafkaSourceBuilder) Annotations

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

Annotations to set metadata.annotations

func (*KafkaSourceBuilder) BootstrapServers

func (b *KafkaSourceBuilder) BootstrapServers(servers []string) *KafkaSourceBuilder

BootstrapServers to set the value of BootstrapServers

func (*KafkaSourceBuilder) Build

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

Build the KafkaSource object

func (*KafkaSourceBuilder) CloudEventOverrides

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

CloudEventOverrides adds given Cloud Event override extensions map to source spec

func (*KafkaSourceBuilder) ConsumerGroup

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

ConsumerGroup to set the value of ConsumerGroup

func (*KafkaSourceBuilder) Labels

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

Labels to set metadata.labels

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