pkg/

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-sandbox/eventing-kafka

Links

Open Source Insights

Directories ¶

Path	Synopsis
apis
bindings Package bindings contains bindings API versions	Package bindings contains bindings API versions
bindings/v1beta1 Package v1beta1 contains API Schema definitions for the sources v1beta1 API group +k8s:openapi-gen=true +k8s:deepcopy-gen=package,register +k8s:defaulter-gen=TypeMeta +groupName=bindings.knative.dev Package v1beta1 contains API Schema definitions for the sources v1beta1 API group +k8s:openapi-gen=true +k8s:deepcopy-gen=package,register +k8s:defaulter-gen=TypeMeta +groupName=sources.knative.dev	Package v1beta1 contains API Schema definitions for the sources v1beta1 API group +k8s:openapi-gen=true +k8s:deepcopy-gen=package,register +k8s:defaulter-gen=TypeMeta +groupName=bindings.knative.dev Package v1beta1 contains API Schema definitions for the sources v1beta1 API group +k8s:openapi-gen=true +k8s:deepcopy-gen=package,register +k8s:defaulter-gen=TypeMeta +groupName=sources.knative.dev
duck/v1alpha1 +k8s:deepcopy-gen=package +groupName=duck.knative.dev	+k8s:deepcopy-gen=package +groupName=duck.knative.dev
kafka
kafka/v1alpha1 Package v1alpha1 is the v1alpha1 version of the API.	Package v1alpha1 is the v1alpha1 version of the API.
messaging
messaging/v1beta1 Package v1beta1 is the v1beta1 version of the API.	Package v1beta1 is the v1beta1 version of the API.
sources Package sources contains sources API versions	Package sources contains sources API versions
sources/v1beta1 Package v1beta1 contains API Schema definitions for the sources v1beta1 API group +k8s:openapi-gen=true +k8s:deepcopy-gen=package,register +k8s:defaulter-gen=TypeMeta +groupName=sources.knative.dev Package v1beta1 contains API Schema definitions for the sources v1beta1 API group +k8s:openapi-gen=true +k8s:deepcopy-gen=package,register +k8s:defaulter-gen=TypeMeta +groupName=sources.knative.dev	Package v1beta1 contains API Schema definitions for the sources v1beta1 API group +k8s:openapi-gen=true +k8s:deepcopy-gen=package,register +k8s:defaulter-gen=TypeMeta +groupName=sources.knative.dev Package v1beta1 contains API Schema definitions for the sources v1beta1 API group +k8s:openapi-gen=true +k8s:deepcopy-gen=package,register +k8s:defaulter-gen=TypeMeta +groupName=sources.knative.dev
channel
consolidated/dispatcher
consolidated/reconciler
consolidated/reconciler/controller
consolidated/reconciler/controller/resources
consolidated/reconciler/dispatcher
consolidated/reconciler/testing
consolidated/status
consolidated/utils
distributed/common/config
distributed/common/env
distributed/common/health
distributed/common/k8s
distributed/common/kafka/admin
distributed/common/kafka/admin/custom
distributed/common/kafka/admin/eventhub
distributed/common/kafka/admin/kafka
distributed/common/kafka/admin/testing
distributed/common/kafka/admin/types
distributed/common/kafka/admin/util
distributed/common/kafka/admin/wrapper
distributed/common/kafka/constants
distributed/common/kafka/consumer
distributed/common/kafka/consumer/testing
distributed/common/kafka/consumer/wrapper
distributed/common/kafka/producer
distributed/common/kafka/producer/testing
distributed/common/kafka/producer/wrapper
distributed/common/kafka/util
distributed/common/util
distributed/controller/config
distributed/controller/constants
distributed/controller/env
distributed/controller/event
distributed/controller/kafkachannel
distributed/controller/testing
distributed/controller/util
distributed/dispatcher/constants
distributed/dispatcher/controller
distributed/dispatcher/dispatcher
distributed/dispatcher/env
distributed/dispatcher/health
distributed/dispatcher/testing
distributed/receiver/channel
distributed/receiver/constants
distributed/receiver/env
distributed/receiver/health
distributed/receiver/producer
distributed/receiver/testing
distributed/receiver/util
webhook
client
clientset/versioned This package has the automatically generated clientset.	This package has the automatically generated clientset.
clientset/versioned/fake This package has the automatically generated fake clientset.	This package has the automatically generated fake clientset.
clientset/versioned/scheme This package contains the scheme of the automatically generated clientset.	This package contains the scheme of the automatically generated clientset.
clientset/versioned/typed/bindings/v1beta1 This package has the automatically generated typed clients.	This package has the automatically generated typed clients.
clientset/versioned/typed/bindings/v1beta1/fake Package fake has the automatically generated clients.	Package fake has the automatically generated clients.
clientset/versioned/typed/kafka/v1alpha1 This package has the automatically generated typed clients.	This package has the automatically generated typed clients.
clientset/versioned/typed/kafka/v1alpha1/fake Package fake has the automatically generated clients.	Package fake has the automatically generated clients.
clientset/versioned/typed/messaging/v1beta1 This package has the automatically generated typed clients.	This package has the automatically generated typed clients.
clientset/versioned/typed/messaging/v1beta1/fake Package fake has the automatically generated clients.	Package fake has the automatically generated clients.
clientset/versioned/typed/sources/v1beta1 This package has the automatically generated typed clients.	This package has the automatically generated typed clients.
clientset/versioned/typed/sources/v1beta1/fake Package fake has the automatically generated clients.	Package fake has the automatically generated clients.
informers/externalversions
informers/externalversions/bindings
informers/externalversions/bindings/v1beta1
informers/externalversions/internalinterfaces
informers/externalversions/kafka
informers/externalversions/kafka/v1alpha1
informers/externalversions/messaging
informers/externalversions/messaging/v1beta1
informers/externalversions/sources
informers/externalversions/sources/v1beta1
injection/client
injection/client/fake
injection/informers/bindings/v1beta1/kafkabinding
injection/informers/bindings/v1beta1/kafkabinding/fake
injection/informers/bindings/v1beta1/kafkabinding/filtered
injection/informers/bindings/v1beta1/kafkabinding/filtered/fake
injection/informers/factory
injection/informers/factory/fake
injection/informers/factory/filtered
injection/informers/factory/filtered/fake
injection/informers/kafka/v1alpha1/resetoffset
injection/informers/kafka/v1alpha1/resetoffset/fake
injection/informers/kafka/v1alpha1/resetoffset/filtered
injection/informers/kafka/v1alpha1/resetoffset/filtered/fake
injection/informers/messaging/v1beta1/kafkachannel
injection/informers/messaging/v1beta1/kafkachannel/fake
injection/informers/messaging/v1beta1/kafkachannel/filtered
injection/informers/messaging/v1beta1/kafkachannel/filtered/fake
injection/informers/sources/v1beta1/kafkasource
injection/informers/sources/v1beta1/kafkasource/fake
injection/informers/sources/v1beta1/kafkasource/filtered
injection/informers/sources/v1beta1/kafkasource/filtered/fake
injection/reconciler/bindings/v1beta1/kafkabinding
injection/reconciler/kafka/v1alpha1/resetoffset
injection/reconciler/messaging/v1beta1/kafkachannel
injection/reconciler/sources/v1beta1/kafkasource
listers/bindings/v1beta1
listers/kafka/v1alpha1
listers/messaging/v1beta1
listers/sources/v1beta1
common
client
client/testing
commands/resetoffset/controller
commands/resetoffset/controller/testing
commands/resetoffset/refmappers
commands/resetoffset/refmappers/testing
config
config/testing
configmaploader
configmaploader/fake
constants
consumer
consumer/testing
controlprotocol
controlprotocol/commands
controlprotocol/testing
kafka/sarama
kafka/testing
metrics
scheduler The scheduler is responsible for placing virtual pod (VPod) replicas within real pods.	The scheduler is responsible for placing virtual pod (VPod) replicas within real pods.
scheduler/statefulset
scheduler/testing
testing
tracing
source
adapter
client
control
mtadapter
reconciler/binding
reconciler/mtsource Package source implements the Multi Tenant KafkaSource controller.	Package source implements the Multi Tenant KafkaSource controller.
reconciler/source Package source implements the KafkaSource controller.	Package source implements the KafkaSource controller.
reconciler/source/resources

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