provider

Documentation

Index

• type ExternalConfigListener
• type ExternalMetricsDriver
• type MetricsLister
  • func NewWavefrontProvider(client dynamic.Interface, mapper apimeta.RESTMapper, ...) (provider.MetricsProvider, MetricsLister)
• type Translator
• type WavefrontExternalDriver
• type WavefrontMetricsLister
  • func (l *WavefrontMetricsLister) ListCustomMetrics() []provider.CustomMetricInfo
  • func (l *WavefrontMetricsLister) ListExternalMetrics() []provider.ExternalMetricInfo
  • func (l *WavefrontMetricsLister) Run()
  • func (l *WavefrontMetricsLister) RunUntil(stopChan <-chan struct{})
• type WavefrontTranslator
  • func (t WavefrontTranslator) CustomMetricsFor(metricNames []string) []provider.CustomMetricInfo
  • func (t WavefrontTranslator) ExternalMetricsFor(metricNames []string) []provider.ExternalMetricInfo
  • func (t WavefrontTranslator) ExternalValuesFor(queryResult wave.QueryResult, name string) (*external_metrics.ExternalMetricValueList, error)
  • func (t WavefrontTranslator) MatchValuesToNames(queryResult wave.QueryResult, groupResource schema.GroupResource) (map[string]float64, bool)
  • func (t WavefrontTranslator) QueryFor(info provider.CustomMetricInfo, namespace string, names ...string) (string, bool)

Types

type ExternalConfigListener

type ExternalConfigListener interface {
	// contains filtered or unexported methods
}

type ExternalMetricsDriver

type ExternalMetricsDriver interface {
	// contains filtered or unexported methods
}

type MetricsLister

type MetricsLister interface {
	Run()
	RunUntil(stopChan <-chan struct{})
	ListCustomMetrics() []provider.CustomMetricInfo
	ListExternalMetrics() []provider.ExternalMetricInfo
}

func NewWavefrontProvider

func NewWavefrontProvider(client dynamic.Interface, mapper apimeta.RESTMapper, waveClient wave.WavefrontClient,
	prefix string, listInterval time.Duration, externalMetricsCfg string) (provider.MetricsProvider, MetricsLister)

type Translator

type Translator interface {
	QueryFor(info provider.CustomMetricInfo, namespace string, names ...string) (string, bool)
	MatchValuesToNames(queryResult wave.QueryResult, groupResource schema.GroupResource) (map[string]float64, bool)
	CustomMetricsFor(metricNames []string) []provider.CustomMetricInfo
	ExternalMetricsFor(metricNames []string) []provider.ExternalMetricInfo
	ExternalValuesFor(queryResult wave.QueryResult, metric string) (*external_metrics.ExternalMetricValueList, error)
}

type WavefrontExternalDriver

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

type WavefrontMetricsLister

type WavefrontMetricsLister struct {
	Prefix         string
	UpdateInterval time.Duration

	Translator
	// contains filtered or unexported fields
}

func (*WavefrontMetricsLister) ListCustomMetrics

func (l *WavefrontMetricsLister) ListCustomMetrics() []provider.CustomMetricInfo

func (*WavefrontMetricsLister) ListExternalMetrics

func (l *WavefrontMetricsLister) ListExternalMetrics() []provider.ExternalMetricInfo

func (*WavefrontMetricsLister) Run

func (l *WavefrontMetricsLister) Run()

func (*WavefrontMetricsLister) RunUntil

func (l *WavefrontMetricsLister) RunUntil(stopChan <-chan struct{})

type WavefrontTranslator

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

func (WavefrontTranslator) CustomMetricsFor

func (t WavefrontTranslator) CustomMetricsFor(metricNames []string) []provider.CustomMetricInfo

func (WavefrontTranslator) ExternalMetricsFor

func (t WavefrontTranslator) ExternalMetricsFor(metricNames []string) []provider.ExternalMetricInfo

func (WavefrontTranslator) ExternalValuesFor

func (t WavefrontTranslator) ExternalValuesFor(queryResult wave.QueryResult, name string) (*external_metrics.ExternalMetricValueList, error)

func (WavefrontTranslator) MatchValuesToNames

func (t WavefrontTranslator) MatchValuesToNames(queryResult wave.QueryResult, groupResource schema.GroupResource) (map[string]float64, bool)

func (WavefrontTranslator) QueryFor

func (t WavefrontTranslator) QueryFor(info provider.CustomMetricInfo, namespace string, names ...string) (string, bool)

Translates given metric info into a Wavefront ts query