Documentation ¶
Overview ¶
Package kafka implements the KafkaSource controller. This is needed to be able to watch channels when delivering to a channel. This is needed to be able to watch the sink when delivering messages directly.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewController ¶ added in v0.10.0
Types ¶
type Reconciler ¶ added in v0.10.0
type Reconciler struct { // KubeClientSet allows us to talk to the k8s for core APIs KubeClientSet kubernetes.Interface // contains filtered or unexported fields }
func (*Reconciler) ReconcileKind ¶ added in v0.13.0
func (r *Reconciler) ReconcileKind(ctx context.Context, src *v1alpha1.KafkaSource) pkgreconciler.Event
func (*Reconciler) UpdateFromLoggingConfigMap ¶ added in v0.10.0
func (r *Reconciler) UpdateFromLoggingConfigMap(cfg *corev1.ConfigMap)
func (*Reconciler) UpdateFromMetricsConfigMap ¶ added in v0.11.0
func (r *Reconciler) UpdateFromMetricsConfigMap(cfg *corev1.ConfigMap)
Click to show internal directories.
Click to hide internal directories.