controller

Documentation

Index

• type KinesisTriggerConfig
• type KinesisTriggerController
  • func NewKinesisTriggerController(cfg KinesisTriggerConfig) *KinesisTriggerController
  • func (c *KinesisTriggerController) FunctionAddedDeletedUpdated(obj interface{}, deleted bool) error
  • func (c *KinesisTriggerController) Run(stopCh <-chan struct{})

Types

type KinesisTriggerConfig

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

KinesisTriggerConfig contains config for KinesisTriggerController

type KinesisTriggerController

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

KinesisTriggerController object

func NewKinesisTriggerController

func NewKinesisTriggerController(cfg KinesisTriggerConfig) *KinesisTriggerController

NewKinesisTriggerController returns a new *KinesisTriggerController.

func (*KinesisTriggerController) FunctionAddedDeletedUpdated

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

FunctionAddedDeletedUpdated process the updates to Function objects

func (*KinesisTriggerController) Run

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

Run starts the Kinesis trigger controller