provider

Apr 3, 2019

Changes in this version

+ func NewPeriodicMetricLister(realLister MetricLister, updateInterval time.Duration) (MetricListerWithNotification, Runnable)

+ type ExternalSeriesRegistry interface

+ ListAllMetrics func() []provider.ExternalMetricInfo

+ QueryForMetric func(namespace string, metricName string, metricSelector labels.Selector) (prom.Selector, bool, error)

+ func NewExternalSeriesRegistry(lister MetricListerWithNotification) ExternalSeriesRegistry

+ type MetricConverter interface

+ Convert func(queryResult prom.QueryResult) (*external_metrics.ExternalMetricValueList, error)

+ func NewMetricConverter() MetricConverter

+ type MetricLister interface

+ ListAllMetrics func() (MetricUpdateResult, error)

+ func NewBasicMetricLister(promClient prom.Client, namers []naming.MetricNamer, lookback time.Duration) MetricLister

+ type MetricListerWithNotification interface

+ AddNotificationReceiver func(MetricUpdateCallback)

+ UpdateNow func()

+ type MetricUpdateCallback func(MetricUpdateResult)

+ type MetricUpdateResult struct

+ type Runnable interface

+ Run func()

+ RunUntil func(stopChan <-chan struct{})

+ func NewExternalPrometheusProvider(promClient prom.Client, namers []naming.MetricNamer, ...) (provider.ExternalMetricsProvider, Runnable)