dispatcher

Documentation

Index

• func New(mgr manager.Manager, logger *zap.Logger) (controller.Controller, error)

Functions

func New

func New(mgr manager.Manager, logger *zap.Logger) (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.