resources

package
v0.41.4 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 29, 2024 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL