resources

Documentation

Index

• func KafkaBindingV1Beta1(bootstrapServer string, ref *tracker.Reference) *kafkabindingv1beta1.KafkaBinding
• func KafkaPerformanceImageSenderPod(pace string, warmup string, bootstrapUrl string, topicName string, ...) *corev1.Pod
• func KafkaSourceV1Beta1(bootstrapServer string, topicName string, ...) *kafkasourcev1beta1.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 KafkaSourceV1Beta1Option
  • func WithConsumerGroupV1Beta1(cg string) KafkaSourceV1Beta1Option
  • func WithExtensionsV1Beta1(extensions map[string]string) KafkaSourceV1Beta1Option
  • func WithNameV1Beta1(name string) KafkaSourceV1Beta1Option

Functions

func KafkaBindingV1Beta1

func KafkaBindingV1Beta1(bootstrapServer string, ref *tracker.Reference) *kafkabindingv1beta1.KafkaBinding

func KafkaPerformanceImageSenderPod

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

func KafkaSourceV1Beta1

func KafkaSourceV1Beta1(bootstrapServer string, topicName string, ordering kafkasourcev1beta1.DeliveryOrdering, ref *corev1.ObjectReference, options ...KafkaSourceV1Beta1Option) *kafkasourcev1beta1.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 KafkaSourceV1Beta1Option

type KafkaSourceV1Beta1Option func(source *kafkasourcev1beta1.KafkaSource)

func WithConsumerGroupV1Beta1

func WithConsumerGroupV1Beta1(cg string) KafkaSourceV1Beta1Option

func WithExtensionsV1Beta1

func WithExtensionsV1Beta1(extensions map[string]string) KafkaSourceV1Beta1Option

func WithNameV1Beta1

func WithNameV1Beta1(name string) KafkaSourceV1Beta1Option