indicator_status

Documentation

Index

• type Controller
  • func NewController(indicatorClient clientSetV1.IndicatorsGetter, promqlClient PromQLClient, ...) *Controller
  • func (c *Controller) OnAdd(obj interface{})
  • func (c *Controller) OnDelete(obj interface{})
  • func (c *Controller) OnUpdate(oldObj, newObj interface{})
  • func (c *Controller) Start()
• type IndicatorStore
  • func NewIndicatorStore() *IndicatorStore
  • func (is *IndicatorStore) Add(indicator v1.Indicator)
  • func (is *IndicatorStore) Delete(indicator v1.Indicator)
  • func (is *IndicatorStore) GetIndicators() []v1.Indicator
  • func (is *IndicatorStore) Update(indicator v1.Indicator)
• type PromQLClient

Types

type Controller

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

func NewController

func NewController(
	indicatorClient clientSetV1.IndicatorsGetter,
	promqlClient PromQLClient,
	interval time.Duration,
	clock clock.Clock,
	namespace string,
	store indicatorStore,
) *Controller

func (*Controller) OnAdd

func (c *Controller) OnAdd(obj interface{})

func (*Controller) OnDelete

func (c *Controller) OnDelete(obj interface{})

func (*Controller) OnUpdate

func (c *Controller) OnUpdate(oldObj, newObj interface{})

func (*Controller) Start

func (c *Controller) Start()

type IndicatorStore

type IndicatorStore struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewIndicatorStore

func NewIndicatorStore() *IndicatorStore

func (*IndicatorStore) Add

func (is *IndicatorStore) Add(indicator v1.Indicator)

func (*IndicatorStore) Delete

func (is *IndicatorStore) Delete(indicator v1.Indicator)

func (*IndicatorStore) GetIndicators

func (is *IndicatorStore) GetIndicators() []v1.Indicator

func (*IndicatorStore) Update

func (is *IndicatorStore) Update(indicator v1.Indicator)

type PromQLClient

type PromQLClient interface {
	QueryVectorValues(query string) ([]float64, error)
}