kafka/

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

Links

Open Source Insights

README ¶

Apache Kafka Componentes for Knative

Apache Kafka Components for Knative support the KafkaChannel and the KafkaSource implementation, which offer ways to integrate Knative with the Apache Kafka broker.

Overview

For details about the KafkaChannel or the KafkaSource, click on the links below:

Directories ¶

Path	Synopsis
channel
cmd/channel_controller
cmd/channel_dispatcher
cmd/webhook
pkg/apis/messaging
pkg/apis/messaging/v1alpha1 Package v1alpha1 is the v1alpha1 version of the API.	Package v1alpha1 is the v1alpha1 version of the API.
pkg/client/clientset/versioned This package has the automatically generated clientset.	This package has the automatically generated clientset.
pkg/client/clientset/versioned/fake This package has the automatically generated fake clientset.	This package has the automatically generated fake clientset.
pkg/client/clientset/versioned/scheme This package contains the scheme of the automatically generated clientset.	This package contains the scheme of the automatically generated clientset.
pkg/client/clientset/versioned/typed/messaging/v1alpha1 This package has the automatically generated typed clients.	This package has the automatically generated typed clients.
pkg/client/clientset/versioned/typed/messaging/v1alpha1/fake Package fake has the automatically generated clients.	Package fake has the automatically generated clients.
pkg/client/informers/externalversions
pkg/client/informers/externalversions/internalinterfaces
pkg/client/informers/externalversions/messaging
pkg/client/informers/externalversions/messaging/v1alpha1
pkg/client/listers/messaging/v1alpha1
pkg/dispatcher
pkg/reconciler
pkg/reconciler/controller
pkg/reconciler/controller/resources
pkg/reconciler/dispatcher
pkg/reconciler/testing
pkg/utils
common
pkg/kafka
source
cmd/controller
cmd/receive_adapter
pkg/adapter
pkg/apis Package apis contains Kubernetes API groups.	Package apis contains Kubernetes API groups.
pkg/apis/sources Package sources contains sources API versions	Package sources contains sources API versions
pkg/apis/sources/v1alpha1 Package v1alpha1 contains API Schema definitions for the sources v1alpha1 API group +k8s:openapi-gen=true +k8s:deepcopy-gen=package,register +k8s:conversion-gen=knative.dev/eventing-contrib/pkg/apis/sources +k8s:defaulter-gen=TypeMeta +groupName=sources.eventing.knative.dev Package v1alpha1 contains API Schema definitions for the sources v1alpha1 API group +k8s:openapi-gen=true +k8s:deepcopy-gen=package,register +k8s:conversion-gen=knative.dev/eventing-contrib/pkg/apis/sources +k8s:defaulter-gen=TypeMeta +groupName=sources.eventing.knative.dev	Package v1alpha1 contains API Schema definitions for the sources v1alpha1 API group +k8s:openapi-gen=true +k8s:deepcopy-gen=package,register +k8s:conversion-gen=knative.dev/eventing-contrib/pkg/apis/sources +k8s:defaulter-gen=TypeMeta +groupName=sources.eventing.knative.dev Package v1alpha1 contains API Schema definitions for the sources v1alpha1 API group +k8s:openapi-gen=true +k8s:deepcopy-gen=package,register +k8s:conversion-gen=knative.dev/eventing-contrib/pkg/apis/sources +k8s:defaulter-gen=TypeMeta +groupName=sources.eventing.knative.dev
pkg/client/clientset/versioned This package has the automatically generated clientset.	This package has the automatically generated clientset.
pkg/client/clientset/versioned/fake This package has the automatically generated fake clientset.	This package has the automatically generated fake clientset.
pkg/client/clientset/versioned/scheme This package contains the scheme of the automatically generated clientset.	This package contains the scheme of the automatically generated clientset.
pkg/client/clientset/versioned/typed/sources/v1alpha1 This package has the automatically generated typed clients.	This package has the automatically generated typed clients.
pkg/client/clientset/versioned/typed/sources/v1alpha1/fake Package fake has the automatically generated clients.	Package fake has the automatically generated clients.
pkg/client/informers/externalversions
pkg/client/informers/externalversions/internalinterfaces
pkg/client/informers/externalversions/sources
pkg/client/informers/externalversions/sources/v1alpha1
pkg/client/injection/client
pkg/client/injection/client/fake
pkg/client/injection/informers/factory
pkg/client/injection/informers/factory/fake
pkg/client/injection/informers/sources/factory
pkg/client/injection/informers/sources/factory/fake
pkg/client/injection/informers/sources/v1alpha1/kafkasource
pkg/client/injection/informers/sources/v1alpha1/kafkasource/fake
pkg/client/listers/sources/v1alpha1
pkg/reconciler Package kafka implements the KafkaSource controller.	Package kafka implements the KafkaSource controller.
pkg/reconciler/resources

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