provider

package
v0.9.9 Latest Latest
Warning

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

Go to latest
Published: Jul 15, 2022 License: Apache-2.0 Imports: 29 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func StartHPAListener added in v0.9.3

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 added in v0.9.3

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

type MetricsLister

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

type RuleHandlerFunc added in v0.9.3

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 added in v0.9.3

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 added in v0.9.3

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

Jump to

Keyboard shortcuts

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