controller

package
v0.0.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 5, 2020 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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 controler 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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL