channel

Documentation

Index

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

Constants

const (
	DefaultNumPartitions = 1
)

Functions

func ProvideController

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

ProvideController returns a Channel controller.