v2

Documentation

Index

• Constants
• func NewControllerV2(ctx context.Context, configs *config.Env) *controller.Impl
• type ReconcilerV2
  • func (r *ReconcilerV2) ReconcileKind(ctx context.Context, trigger *eventing.Trigger) reconciler.Event

Constants

const (
	ControllerAgentName = "kafka-trigger-controller"

	FinalizerName = "kafka.triggers.eventing.knative.dev"
)

Functions

func NewControllerV2

func NewControllerV2(ctx context.Context, configs *config.Env) *controller.Impl

Types

type ReconcilerV2

type ReconcilerV2 struct {
	BrokerLister        eventinglisters.BrokerLister
	EventingClient      eventingclientset.Interface
	Env                 *config.Env
	ConsumerGroupLister internalslst.ConsumerGroupLister
	InternalsClient     internalsclient.Interface
}

func (*ReconcilerV2) ReconcileKind

func (r *ReconcilerV2) ReconcileKind(ctx context.Context, trigger *eventing.Trigger) reconciler.Event