clusterchannelprovisioner

Documentation

Index

• Constants
• func IsControlled(ref *corev1.ObjectReference) bool
• func ProvideController(mgr manager.Manager, natssURL, clusterID string, logger *zap.Logger) (controller.Controller, error)

Constants

const (
	// Name is the name of NATSS ClusterChannelProvisioner.
	Name = "natss"
	// Channel is the name of the Channel resource in eventing.knative.dev/v1alpha1.
	Channel = "Channel"
)

Functions

func IsControlled

func IsControlled(ref *corev1.ObjectReference) bool

IsControlled determines if the in-memory Channel Controller should control (and therefore reconcile) a given object, based on that object's ClusterChannelProvisioner reference.

func ProvideController

func ProvideController(mgr manager.Manager, natssURL, clusterID string, logger *zap.Logger) (controller.Controller, error)

ProvideController returns a flow controller.