controller

Documentation

Index

• type Config
• type FunctionController
  • func NewFunctionController(cfg Config, smclient *monitoringv1alpha1.MonitoringV1alpha1Client) *FunctionController
  • func (c *FunctionController) HasSynced() bool
  • func (c *FunctionController) LastSyncResourceVersion() string
  • func (c *FunctionController) Run(stopCh <-chan struct{})

Types

type Config

type Config struct {
	KubeCli        kubernetes.Interface
	FunctionClient versioned.Interface
}

Config contains k8s client of a controller

type FunctionController

type FunctionController struct {
	Functions map[string]*kubelessApi.Function
	// contains filtered or unexported fields
}

FunctionController object

func NewFunctionController

func NewFunctionController(cfg Config, smclient *monitoringv1alpha1.MonitoringV1alpha1Client) *FunctionController

NewFunctionController returns a new *FunctionController

func (*FunctionController) HasSynced

func (c *FunctionController) HasSynced() bool

HasSynced is required for the cache.Controller interface.

func (*FunctionController) LastSyncResourceVersion

func (c *FunctionController) LastSyncResourceVersion() string

LastSyncResourceVersion is required for the cache.Controller interface.

func (*FunctionController) Run

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

Run starts the kubeless controller