resources

package

v0.41.0 Latest Latest Go to latest Published: Apr 30, 2024 License: Apache-2.0 Imports: 20 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/knative-extensions/eventing-kafka-broker

Links

Open Source Insights

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
type KafkaSourceV1Beta1Option

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

Source Files ¶

View all Source files

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