controller

Documentation

Index

• type Controller
  • func NewController(externalMetricInformer informers.ExternalMetricInformer, ...) *Controller
  • func (c *Controller) Run(numberOfWorkers int, interval time.Duration, stopCh <-chan struct{})
• type ControllerHandler
• type Handler
  • func NewHandler(externalmetricLister listers.ExternalMetricLister, ...) Handler
  • func (h *Handler) Process(queueItem namespacedQueueItem) error

Types

type Controller

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

Controller will do the work of syncing the external metrics the metric adapter knows about.

func NewController

func NewController(externalMetricInformer informers.ExternalMetricInformer, metricHandler ControllerHandler) *Controller

NewController returns a new controller for handling external metric types

func (*Controller) Run

func (c *Controller) Run(numberOfWorkers int, interval time.Duration, stopCh <-chan struct{})

Run is the main path of execution for the controller loop

type ControllerHandler

type ControllerHandler interface {
	Process(queueItem namespacedQueueItem) error
}

ControllerHandler is a handler to process resource items

type Handler

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

Handler processes the events from the controller for external metrics

func NewHandler

func NewHandler(externalmetricLister listers.ExternalMetricLister, metricCache *metriccache.MetricCache) Handler

NewHandler created a new handler

func (*Handler) Process

func (h *Handler) Process(queueItem namespacedQueueItem) error

Process validates the item exists then stores updates the metric cached used to make requests to cloudwatch