dispatcher

Documentation

Index

• func New(mgr manager.Manager, logger *zap.Logger, additionalHandlers []ReconcileHandler) (controller.Controller, error)
• type ReconcileHandler

Functions

func New

func New(mgr manager.Manager, logger *zap.Logger, additionalHandlers []ReconcileHandler) (controller.Controller, error)

New returns a Controller that represents the dispatcher portion (messages from GCP PubSub are sent into the cluster) of the GCP PubSub dispatcher. We use a reconcile loop to watch all Channels and notice changes to them. It uses an exponential backoff to throttle the retries.

Types

type ReconcileHandler

type ReconcileHandler func(context.Context, reconcile.Request) error

ReconcileHandler will be run by in addition to existing reconcile.