provider

Documentation

Index

• func StartHPAListener(client kubernetes.Interface, addFunc, deleteFunc RuleHandlerFunc)
• type ExternalConfigListener
• type ExternalMetricsDriver
  • func NewExternalMetricsDriver(client kubernetes.Interface, cfgFile string) ExternalMetricsDriver
• type MetricsLister
  • func NewWavefrontProvider(cfg WavefrontProviderConfig) (provider.MetricsProvider, MetricsLister)
• type RuleHandlerFunc
• type Translator
  • func NewWavefrontTranslator(prefix string) 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 WavefrontProviderConfig

Functions

func StartHPAListener

func StartHPAListener(client kubernetes.Interface, addFunc, deleteFunc RuleHandlerFunc)

Types

type ExternalConfigListener

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

type ExternalMetricsDriver

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

func NewExternalMetricsDriver

func NewExternalMetricsDriver(client kubernetes.Interface, cfgFile string) ExternalMetricsDriver

type MetricsLister

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

func NewWavefrontProvider

func NewWavefrontProvider(cfg WavefrontProviderConfig) (provider.MetricsProvider, MetricsLister)

type RuleHandlerFunc

type RuleHandlerFunc func([]config.MetricRule)

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)
}

func NewWavefrontTranslator

func NewWavefrontTranslator(prefix string) Translator

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 WavefrontProviderConfig

type WavefrontProviderConfig struct {
	DynClient    dynamic.Interface
	KubeClient   kubernetes.Interface
	Mapper       apimeta.RESTMapper
	WaveClient   wave.WavefrontClient
	Prefix       string
	ListInterval time.Duration
	ExternalCfg  string
}