Controller Implementation and Design

Controller Implementation

cmd/controller

Pass the new controller implementation to the shared main

import (
	// The set of controllers this controller process runs.
	"knative.dev/sample-source/pkg/reconciler"

	// This defines the shared main for injected controllers.
	"knative.dev/pkg/injection/sharedmain"
)

func main() {
	sharedmain.Main("sample-source-controller",
		reconciler.NewController
	)
}

Define the NewController implementation, it will be passed a configmap.Watcher, as well as a context which the injected listers will use for the reconciler struct arguments

func NewController(
	ctx context.Context,
	cmw configmap.Watcher,
) *controller.Impl {
    // ...
	sampleSourceInformer := samplesourceinformer.Get(ctx)

	r := &Reconciler{
		KubeClientSet:         kubeclient.Get(ctx),
		EventingClientSet:     eventingclient.Get(ctx),
		samplesourceLister:    sampleSourceInformer.Lister(),
		deploymentLister:      deploymentInformer.Lister(),
		samplesourceClientSet: samplesourceClient.Get(ctx),
	}

The base reconciler is imported from the knative.dev/pkg dependency:

import (
    // ...
    "knative.dev/eventing/pkg/reconciler"
    // ...
)

Ensure the correct informers have EventHandlers filtered to them

	sampleSourceInformer.Informer().AddEventHandler(controller.HandleAll(impl.Enqueue))