control-plane/

Directories ¶

Path	Synopsis
cmd
kafka-controller
kafka-source-controller
post-install
webhook-kafka
pkg
apis/bindings Package bindings contains bindings API versions	Package bindings contains bindings API versions
apis/bindings/v1 Package v1 contains API Schema definitions for the sources v1 API group +k8s:openapi-gen=true +k8s:deepcopy-gen=package,register +k8s:defaulter-gen=TypeMeta +groupName=bindings.knative.dev	Package v1 contains API Schema definitions for the sources v1 API group +k8s:openapi-gen=true +k8s:deepcopy-gen=package,register +k8s:defaulter-gen=TypeMeta +groupName=bindings.knative.dev
apis/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=bindings.knative.dev
apis/config
apis/core
apis/eventing
apis/eventing/v1
apis/eventing/v1alpha1 +k8s:deepcopy-gen=package +groupName=eventing.knative.dev	+k8s:deepcopy-gen=package +groupName=eventing.knative.dev
apis/internalskafkaeventing
apis/internalskafkaeventing/v1alpha1 +k8s:deepcopy-gen=package +groupName=internal.kafka.eventing.knative.dev	+k8s:deepcopy-gen=package +groupName=internal.kafka.eventing.knative.dev
apis/messaging
apis/messaging/v1beta1 Package v1beta1 is the v1beta1 version of the API.	Package v1beta1 is the v1beta1 version of the API.
apis/sources/config Package config holds the typed objects that define the schemas for ConfigMap objects that pertain to our API objects.	Package config holds the typed objects that define the schemas for ConfigMap objects that pertain to our API objects.
apis/sources/v1 Package v1 contains API Schema definitions for the sources v1 API group +k8s:openapi-gen=true +k8s:deepcopy-gen=package,register +k8s:defaulter-gen=TypeMeta +groupName=sources.knative.dev	Package v1 contains API Schema definitions for the sources v1 API group +k8s:openapi-gen=true +k8s:deepcopy-gen=package,register +k8s:defaulter-gen=TypeMeta +groupName=sources.knative.dev
apis/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
autoscaler
autoscaler/keda
client/clientset/versioned
client/clientset/versioned/fake This package has the automatically generated fake clientset.	This package has the automatically generated fake clientset.
client/clientset/versioned/scheme This package contains the scheme of the automatically generated clientset.	This package contains the scheme of the automatically generated clientset.
client/clientset/versioned/typed/bindings/v1 This package has the automatically generated typed clients.	This package has the automatically generated typed clients.
client/clientset/versioned/typed/bindings/v1/fake Package fake has the automatically generated clients.	Package fake has the automatically generated clients.
client/clientset/versioned/typed/bindings/v1beta1 This package has the automatically generated typed clients.	This package has the automatically generated typed clients.
client/clientset/versioned/typed/bindings/v1beta1/fake Package fake has the automatically generated clients.	Package fake has the automatically generated clients.
client/clientset/versioned/typed/eventing/v1alpha1 This package has the automatically generated typed clients.	This package has the automatically generated typed clients.
client/clientset/versioned/typed/eventing/v1alpha1/fake Package fake has the automatically generated clients.	Package fake has the automatically generated clients.
client/clientset/versioned/typed/internalskafkaeventing/v1alpha1 This package has the automatically generated typed clients.	This package has the automatically generated typed clients.
client/clientset/versioned/typed/internalskafkaeventing/v1alpha1/fake Package fake has the automatically generated clients.	Package fake has the automatically generated clients.
client/clientset/versioned/typed/messaging/v1beta1 This package has the automatically generated typed clients.	This package has the automatically generated typed clients.
client/clientset/versioned/typed/messaging/v1beta1/fake Package fake has the automatically generated clients.	Package fake has the automatically generated clients.
client/clientset/versioned/typed/sources/v1 This package has the automatically generated typed clients.	This package has the automatically generated typed clients.
client/clientset/versioned/typed/sources/v1/fake Package fake has the automatically generated clients.	Package fake has the automatically generated clients.
client/clientset/versioned/typed/sources/v1beta1 This package has the automatically generated typed clients.	This package has the automatically generated typed clients.
client/clientset/versioned/typed/sources/v1beta1/fake Package fake has the automatically generated clients.	Package fake has the automatically generated clients.
client/informers/externalversions
client/informers/externalversions/bindings
client/informers/externalversions/bindings/v1
client/informers/externalversions/bindings/v1beta1
client/informers/externalversions/eventing
client/informers/externalversions/eventing/v1alpha1
client/informers/externalversions/internalinterfaces
client/informers/externalversions/internalskafkaeventing
client/informers/externalversions/internalskafkaeventing/v1alpha1
client/informers/externalversions/messaging
client/informers/externalversions/messaging/v1beta1
client/informers/externalversions/sources
client/informers/externalversions/sources/v1
client/informers/externalversions/sources/v1beta1
client/injection/client
client/injection/client/fake
client/injection/informers/bindings/v1beta1/kafkabinding
client/injection/informers/bindings/v1beta1/kafkabinding/fake
client/injection/informers/bindings/v1beta1/kafkabinding/filtered
client/injection/informers/bindings/v1beta1/kafkabinding/filtered/fake
client/injection/informers/eventing/v1alpha1/kafkasink
client/injection/informers/eventing/v1alpha1/kafkasink/fake
client/injection/informers/eventing/v1alpha1/kafkasink/filtered
client/injection/informers/eventing/v1alpha1/kafkasink/filtered/fake
client/injection/informers/factory
client/injection/informers/factory/fake
client/injection/informers/factory/filtered
client/injection/informers/factory/filtered/fake
client/injection/informers/internalskafkaeventing/v1alpha1/consumer
client/injection/informers/internalskafkaeventing/v1alpha1/consumer/fake
client/injection/informers/internalskafkaeventing/v1alpha1/consumer/filtered
client/injection/informers/internalskafkaeventing/v1alpha1/consumer/filtered/fake
client/injection/informers/internalskafkaeventing/v1alpha1/consumergroup
client/injection/informers/internalskafkaeventing/v1alpha1/consumergroup/fake
client/injection/informers/internalskafkaeventing/v1alpha1/consumergroup/filtered
client/injection/informers/internalskafkaeventing/v1alpha1/consumergroup/filtered/fake
client/injection/informers/messaging/v1beta1/kafkachannel
client/injection/informers/messaging/v1beta1/kafkachannel/fake
client/injection/informers/messaging/v1beta1/kafkachannel/filtered
client/injection/informers/messaging/v1beta1/kafkachannel/filtered/fake
client/injection/informers/sources/v1/kafkasource
client/injection/informers/sources/v1/kafkasource/fake
client/injection/informers/sources/v1/kafkasource/filtered
client/injection/informers/sources/v1/kafkasource/filtered/fake
client/injection/informers/sources/v1beta1/kafkasource
client/injection/informers/sources/v1beta1/kafkasource/fake
client/injection/informers/sources/v1beta1/kafkasource/filtered
client/injection/informers/sources/v1beta1/kafkasource/filtered/fake
client/injection/reconciler/bindings/v1beta1/kafkabinding
client/injection/reconciler/eventing/v1alpha1/kafkasink
client/injection/reconciler/internalskafkaeventing/v1alpha1/consumer
client/injection/reconciler/internalskafkaeventing/v1alpha1/consumergroup
client/injection/reconciler/messaging/v1beta1/kafkachannel
client/injection/reconciler/sources/v1/kafkasource
client/injection/reconciler/sources/v1beta1/kafkasource
client/listers/bindings/v1
client/listers/bindings/v1beta1
client/listers/eventing/v1alpha1
client/listers/internalskafkaeventing/v1alpha1
client/listers/messaging/v1beta1
client/listers/sources/v1
client/listers/sources/v1beta1
config
contract
core/config
counter
kafka
kafka/clientpool
kafka/offset
kafka/sarama
kafka/testing
logging
prober
prober/probertesting
propagator
receiver
reconciler/base receiver_condition_set.go contains Broker and Kafka Sink logic for status conditions handling.	receiver_condition_set.go contains Broker and Kafka Sink logic for status conditions handling.
reconciler/broker
reconciler/channel
reconciler/channel/apis/messaging
reconciler/channel/resources
reconciler/consumer
reconciler/consumergroup
reconciler/sink
reconciler/source
reconciler/testing
reconciler/trigger
reconciler/trigger/v2
security
util

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