Documentation ¶
Index ¶
Constants ¶
View Source
const ( ControllerAgentName = "kafka-trigger-controller" FinalizerName = "kafka.triggers.eventing.knative.dev" )
Variables ¶
This section is empty.
Functions ¶
func NewController ¶ added in v0.29.0
Types ¶
type Reconciler ¶ added in v0.29.0
type Reconciler struct { BrokerLister eventinglisters.BrokerLister ConfigMapLister corelisters.ConfigMapLister EventingClient eventingclientset.Interface Env *config.Env ConsumerGroupLister internalslst.ConsumerGroupLister InternalsClient internalsclient.Interface }
func (*Reconciler) ReconcileKind ¶ added in v0.29.0
func (r *Reconciler) ReconcileKind(ctx context.Context, trigger *eventing.Trigger) reconciler.Event
Click to show internal directories.
Click to hide internal directories.