gcppubsub

Documentation

Overview

Package gcppubsub implements the GcpPubSubSource controller. This is needed to be able to watch channels when delivering to a channel. This is needed to be able to watch the sink when delivering messages directly.

Index

• func Add(mgr manager.Manager, logger *zap.SugaredLogger) error

Functions

func Add

func Add(mgr manager.Manager, logger *zap.SugaredLogger) error

Add creates a new GcpPubSubSource Controller and adds it to the Manager with default RBAC. The Manager will set fields on the Controller and Start it when the Manager is Started.