resources

Documentation

Index

• func KafkaPerformanceImageSenderPod(pace string, warmup string, bootstrapUrl string, topicName string, ...) *corev1.Pod
• func KafkaSource(bootstrapServer string, topicName string, ordering sources.DeliveryOrdering, ...) *sources.KafkaSource
• func NewKafkaChannel(name, namespace string, ncopt ...KafkaChannelOption) *v1beta1.KafkaChannel
• func WithInitKafkaChannelConditions(nc *v1beta1.KafkaChannel)
• func WithKafkaChannelDeleted(nc *v1beta1.KafkaChannel)
• type KafkaChannelOption
  • func WithKafkaChannelAddress(a string) KafkaChannelOption
  • func WithKafkaChannelChannelServiceReady() KafkaChannelOption
  • func WithKafkaChannelChannelServicetNotReady(reason, message string) KafkaChannelOption
  • func WithKafkaChannelConfigReady() KafkaChannelOption
  • func WithKafkaChannelDeploymentNotReady(reason, message string) KafkaChannelOption
  • func WithKafkaChannelDeploymentReady() KafkaChannelOption
  • func WithKafkaChannelEndpointsNotReady(reason, message string) KafkaChannelOption
  • func WithKafkaChannelEndpointsReady() KafkaChannelOption
  • func WithKafkaChannelServiceReady() KafkaChannelOption
  • func WithKafkaChannelServicetNotReady(reason, message string) KafkaChannelOption
  • func WithKafkaChannelStatusSubscribers() KafkaChannelOption
  • func WithKafkaChannelSubscribers(subs []v1.SubscriberSpec) KafkaChannelOption
  • func WithKafkaChannelTopicReady() KafkaChannelOption
  • func WithKafkaFinalizer(finalizerName string) KafkaChannelOption
• type KafkaSourceOption
  • func WithConsumerGroup(cg string) KafkaSourceOption
  • func WithExtensions(extensions map[string]string) KafkaSourceOption
  • func WithName(name string) KafkaSourceOption

Functions

func KafkaPerformanceImageSenderPod

func KafkaPerformanceImageSenderPod(pace string, warmup string, bootstrapUrl string, topicName string, aggregatorHostname string, additionalArgs ...string) *corev1.Pod

func KafkaSource

func KafkaSource(bootstrapServer string, topicName string, ordering sources.DeliveryOrdering, ref *corev1.ObjectReference, options ...KafkaSourceOption) *sources.KafkaSource

func NewKafkaChannel

func NewKafkaChannel(name, namespace string, ncopt ...KafkaChannelOption) *v1beta1.KafkaChannel

NewKafkaChannel creates an KafkaChannel with KafkaChannelOptions.

func WithInitKafkaChannelConditions

func WithInitKafkaChannelConditions(nc *v1beta1.KafkaChannel)

func WithKafkaChannelDeleted

func WithKafkaChannelDeleted(nc *v1beta1.KafkaChannel)

Types

type KafkaChannelOption

type KafkaChannelOption func(*v1beta1.KafkaChannel)

KafkaChannelOption enables further configuration of a KafkaChannel.

func WithKafkaChannelAddress

func WithKafkaChannelAddress(a string) KafkaChannelOption

func WithKafkaChannelChannelServiceReady

func WithKafkaChannelChannelServiceReady() KafkaChannelOption

func WithKafkaChannelChannelServicetNotReady

func WithKafkaChannelChannelServicetNotReady(reason, message string) KafkaChannelOption

func WithKafkaChannelConfigReady

func WithKafkaChannelConfigReady() KafkaChannelOption

func WithKafkaChannelDeploymentNotReady

func WithKafkaChannelDeploymentNotReady(reason, message string) KafkaChannelOption

func WithKafkaChannelDeploymentReady

func WithKafkaChannelDeploymentReady() KafkaChannelOption

func WithKafkaChannelEndpointsNotReady

func WithKafkaChannelEndpointsNotReady(reason, message string) KafkaChannelOption

func WithKafkaChannelEndpointsReady

func WithKafkaChannelEndpointsReady() KafkaChannelOption

func WithKafkaChannelServiceReady

func WithKafkaChannelServiceReady() KafkaChannelOption

func WithKafkaChannelServicetNotReady

func WithKafkaChannelServicetNotReady(reason, message string) KafkaChannelOption

func WithKafkaChannelStatusSubscribers

func WithKafkaChannelStatusSubscribers() KafkaChannelOption

func WithKafkaChannelSubscribers

func WithKafkaChannelSubscribers(subs []v1.SubscriberSpec) KafkaChannelOption

func WithKafkaChannelTopicReady

func WithKafkaChannelTopicReady() KafkaChannelOption

func WithKafkaFinalizer

func WithKafkaFinalizer(finalizerName string) KafkaChannelOption

type KafkaSourceOption

type KafkaSourceOption func(source *sources.KafkaSource)

func WithConsumerGroup

func WithConsumerGroup(cg string) KafkaSourceOption

func WithExtensions

func WithExtensions(extensions map[string]string) KafkaSourceOption

func WithName

func WithName(name string) KafkaSourceOption