resources

Documentation

Index

• func KafkaBindingV1Alpha1(bootstrapServer string, ref *tracker.Reference) *kafkabindingv1alpha1.KafkaBinding
• func KafkaBindingV1Beta1(bootstrapServer string, ref *tracker.Reference) *kafkabindingv1beta1.KafkaBinding
• func KafkaPerformanceImageSenderPod(pace string, warmup string, bootstrapUrl string, topicName string, ...) *corev1.Pod
• func KafkaSourceV1Alpha1(bootstrapServer string, topicName string, ref *corev1.ObjectReference, ...) *kafkasourcev1alpha1.KafkaSource
• func KafkaSourceV1Beta1(bootstrapServer string, topicName string, ref *corev1.ObjectReference, ...) *kafkasourcev1beta1.KafkaSource
• type KafkaSourceV1Alpha1Option
  • func WithConsumerGroupV1Alpha1(cg string) KafkaSourceV1Alpha1Option
  • func WithNameV1Alpha1(name string) KafkaSourceV1Alpha1Option
• type KafkaSourceV1Beta1Option
  • func WithConsumerGroupV1Beta1(cg string) KafkaSourceV1Beta1Option
  • func WithNameV1Beta1(name string) KafkaSourceV1Beta1Option

Functions

func KafkaBindingV1Alpha1

func KafkaBindingV1Alpha1(bootstrapServer string, ref *tracker.Reference) *kafkabindingv1alpha1.KafkaBinding

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 KafkaSourceV1Alpha1

func KafkaSourceV1Alpha1(bootstrapServer string, topicName string, ref *corev1.ObjectReference, options ...KafkaSourceV1Alpha1Option) *kafkasourcev1alpha1.KafkaSource

func KafkaSourceV1Beta1

func KafkaSourceV1Beta1(bootstrapServer string, topicName string, ref *corev1.ObjectReference, options ...KafkaSourceV1Beta1Option) *kafkasourcev1beta1.KafkaSource

Types

type KafkaSourceV1Alpha1Option

type KafkaSourceV1Alpha1Option func(source *kafkasourcev1alpha1.KafkaSource)

func WithConsumerGroupV1Alpha1

func WithConsumerGroupV1Alpha1(cg string) KafkaSourceV1Alpha1Option

func WithNameV1Alpha1

func WithNameV1Alpha1(name string) KafkaSourceV1Alpha1Option

type KafkaSourceV1Beta1Option

type KafkaSourceV1Beta1Option func(source *kafkasourcev1beta1.KafkaSource)

func WithConsumerGroupV1Beta1

func WithConsumerGroupV1Beta1(cg string) KafkaSourceV1Beta1Option

func WithNameV1Beta1

func WithNameV1Beta1(name string) KafkaSourceV1Beta1Option