provider

Documentation

Index

• type Runnable
  • func NewPrometheusProvider(mapper apimeta.RESTMapper, kubeClient dynamic.Interface, ...) (provider.CustomMetricsProvider, Runnable)
• type SeriesRegistry
• type SeriesType

Types

type Runnable

type Runnable interface {
	// Run runs the runnable forever.
	Run()
	// RunUntil runs the runnable until the given channel is closed.
	RunUntil(stopChan <-chan struct{})
}

Runnable represents something that can be run until told to stop.

func NewPrometheusProvider

func NewPrometheusProvider(mapper apimeta.RESTMapper, kubeClient dynamic.Interface, promClient prom.Client, namers []naming.MetricNamer, updateInterval time.Duration, maxAge time.Duration) (provider.CustomMetricsProvider, Runnable)

type SeriesRegistry

type SeriesRegistry interface {
	// SetSeries replaces the known series in this registry.
	// Each slice in series should correspond to a MetricNamer in namers.
	SetSeries(series [][]prom.Series, namers []naming.MetricNamer) error
	// ListAllMetrics lists all metrics known to this registry
	ListAllMetrics() []provider.CustomMetricInfo
	// SeriesForMetric looks up the minimum required series information to make a query for the given metric
	// against the given resource (namespace may be empty for non-namespaced resources)
	QueryForMetric(info provider.CustomMetricInfo, namespace string, resourceNames ...string) (query prom.Selector, found bool)
	// MatchValuesToNames matches result values to resource names for the given metric and value set
	MatchValuesToNames(metricInfo provider.CustomMetricInfo, values pmodel.Vector) (matchedValues map[string]pmodel.SampleValue, found bool)
}

SeriesRegistry provides conversions between Prometheus series and MetricInfo

type SeriesType

type SeriesType int

SeriesType represents the kind of series backing a metric.

const (
	CounterSeries SeriesType = iota
	SecondsCounterSeries
	GaugeSeries
)