controller

Documentation

Index

• type NatsTriggerConfig
• type NatsTriggerController
  • func NewNatsTriggerController(cfg NatsTriggerConfig) *NatsTriggerController
  • func (c *NatsTriggerController) FunctionAddedDeletedUpdated(obj interface{}, deleted bool)
  • func (c *NatsTriggerController) Run(stopCh <-chan struct{})

Types

type NatsTriggerConfig

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

NatsTriggerConfig contains config for NatsTriggerController

type NatsTriggerController

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

NatsTriggerController object

func NewNatsTriggerController

func NewNatsTriggerController(cfg NatsTriggerConfig) *NatsTriggerController

NewNatsTriggerController returns a new *NatsTriggerController.

func (*NatsTriggerController) FunctionAddedDeletedUpdated

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

FunctionAddedDeletedUpdated process the updates to Function objects

func (*NatsTriggerController) Run

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

Run starts the nats trigger controller