Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct {
KubeCli kubernetes.Interface
FunctionClient versioned.Interface
}
Config contains k8s client of a controller
type CronJobTriggerConfig ¶ added in v0.5.0
type CronJobTriggerConfig struct {
KubeCli kubernetes.Interface
TriggerClient versioned.Interface
}
CronJobTriggerConfig contains config for CronJobTriggerController
type CronJobTriggerController ¶ added in v0.5.0
type CronJobTriggerController struct {
// contains filtered or unexported fields
}
CronJobTriggerController object
func NewCronJobTriggerController ¶ added in v0.5.0
func NewCronJobTriggerController(cfg CronJobTriggerConfig, sharedInformerFactory externalversions.SharedInformerFactory) *CronJobTriggerController
NewCronJobTriggerController initializes a controller object
func (*CronJobTriggerController) Run ¶ added in v0.5.0
func (c *CronJobTriggerController) Run(stopCh <-chan struct{})
Run starts the Trigger controller
func (*CronJobTriggerController) WaitForCacheSync ¶ added in v0.5.0
func (c *CronJobTriggerController) WaitForCacheSync(stopCh <-chan struct{}) bool
WaitForCacheSync is required for caches to be synced
type FunctionController ¶ added in v0.5.0
type FunctionController struct {
Functions map[string]*kubelessApi.Function
// contains filtered or unexported fields
}
FunctionController object
func NewFunctionController ¶ added in v0.5.0
func NewFunctionController(cfg Config, smclient *monitoringv1alpha1.MonitoringV1alpha1Client) *FunctionController
NewFunctionController returns a new *FunctionController
func (*FunctionController) HasSynced ¶ added in v0.5.0
func (c *FunctionController) HasSynced() bool
HasSynced is required for the cache.Controller interface.
func (*FunctionController) LastSyncResourceVersion ¶ added in v0.5.0
func (c *FunctionController) LastSyncResourceVersion() string
LastSyncResourceVersion is required for the cache.Controller interface.
func (*FunctionController) Run ¶ added in v0.5.0
func (c *FunctionController) Run(stopCh <-chan struct{})
Run starts the kubeless controller
type HTTPTriggerConfig ¶ added in v0.5.0
type HTTPTriggerConfig struct {
KubeCli kubernetes.Interface
TriggerClient versioned.Interface
}
HTTPTriggerConfig contains k8s client of a controller
type HTTPTriggerController ¶ added in v0.5.0
type HTTPTriggerController struct {
// contains filtered or unexported fields
}
HTTPTriggerController object
func NewHTTPTriggerController ¶ added in v0.5.0
func NewHTTPTriggerController(cfg HTTPTriggerConfig, sharedInformerFactory externalversions.SharedInformerFactory) *HTTPTriggerController
NewHTTPTriggerController initializes a controller object
func (*HTTPTriggerController) HasSynced ¶ added in v0.5.0
func (c *HTTPTriggerController) HasSynced() bool
HasSynced is required for the cache.Controller interface.
func (*HTTPTriggerController) Run ¶ added in v0.5.0
func (c *HTTPTriggerController) Run(stopCh <-chan struct{})
Run starts the Trigger controller
type KafkaTriggerConfig ¶ added in v0.5.0
KafkaTriggerConfig contains config for KafkaTriggerController
type KafkaTriggerController ¶ added in v0.5.0
type KafkaTriggerController struct {
// contains filtered or unexported fields
}
KafkaTriggerController object
func NewKafkaTriggerController ¶ added in v0.5.0
func NewKafkaTriggerController(cfg KafkaTriggerConfig) *KafkaTriggerController
NewKafkaTriggerController returns a new *KafkaTriggerController.
func (*KafkaTriggerController) FunctionAddedDeletedUpdated ¶ added in v0.5.0
func (c *KafkaTriggerController) FunctionAddedDeletedUpdated(obj interface{}, deleted bool)
FunctionAddedDeletedUpdated process the updates to Function objects
func (*KafkaTriggerController) Run ¶ added in v0.5.0
func (c *KafkaTriggerController) Run(stopCh <-chan struct{})
Run starts the Kafka trigger controller
Source Files