controller

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(externalMetricInformer informers.ExternalMetricInformer, customMetricInformer informers.CustomMetricInformer, metricHandler ControllerHandler) *Controller

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

type ControllerHandler ¶ added in v0.6.0

type ControllerHandler interface {
	Process(queueItem namespacedQueueItem) error
}

type Handler ¶

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

Handler processes the events from the controler for external metrics

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

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