controller

Documentation

Index

• type KafkaTriggerConfig
• type KafkaTriggerController
  • func NewKafkaTriggerController(cfg KafkaTriggerConfig) *KafkaTriggerController
  • func (c *KafkaTriggerController) FunctionAddedDeletedUpdated(obj interface{}, deleted bool)
  • func (c *KafkaTriggerController) Run(stopCh <-chan struct{})

Types

type KafkaTriggerConfig

type KafkaTriggerConfig struct {
	KubeCli        kubernetes.Interface
	TriggerClient  versioned.Interface
	KubelessClient kubelessversioned.Interface
}

KafkaTriggerConfig contains config for KafkaTriggerController

type KafkaTriggerController

type KafkaTriggerController struct {
	// contains filtered or unexported fields
}

KafkaTriggerController object

func NewKafkaTriggerController

func NewKafkaTriggerController(cfg KafkaTriggerConfig) *KafkaTriggerController

NewKafkaTriggerController returns a new *KafkaTriggerController.

func (*KafkaTriggerController) FunctionAddedDeletedUpdated

func (c *KafkaTriggerController) FunctionAddedDeletedUpdated(obj interface{}, deleted bool)

FunctionAddedDeletedUpdated process the updates to Function objects

func (*KafkaTriggerController) Run

func (c *KafkaTriggerController) Run(stopCh <-chan struct{})

Run starts the Kafka trigger controller