controller

Documentation

Index

• Constants
• func ProvideController(mgr manager.Manager, config *utils.KafkaConfig, logger *zap.Logger) (controller.Controller, error)

Constants

const (

	// ConfigMapName is the name of the ConfigMap in the knative-eventing namespace that contains
	// the subscription information for all kafka Channels. The Provisioner writes to it and the
	// Dispatcher reads from it.
	DispatcherConfigMapName = "kafka-channel-dispatcher"
)

const (
	// Name is the name of the kafka ClusterChannelProvisioner.
	Name = "kafka"
)

Functions

func ProvideController

func ProvideController(mgr manager.Manager, config *utils.KafkaConfig, logger *zap.Logger) (controller.Controller, error)

ProvideController returns a Provisioner controller.