metrics

Documentation

Index

• func ConstructOrUpdateMetric(metric prometheus.Metric, metricSpec *wfv1.Prometheus) (prometheus.Metric, error)
• func ConstructRealTimeGaugeMetric(metricSpec *wfv1.Prometheus, valueFunc func() float64) prometheus.Metric
• func NewMetricsRegistry(metricsProvider MetricsProvider, informer cache.SharedIndexInformer, ...) *prometheus.Registry
• func NewTelemetryRegistry() *prometheus.Registry
• func RunServer(ctx context.Context, config config.PrometheusConfig, ...)
• type MetricsProvider
• type RealTimeMetric

Functions

func ConstructOrUpdateMetric

func ConstructOrUpdateMetric(metric prometheus.Metric, metricSpec *wfv1.Prometheus) (prometheus.Metric, error)

func ConstructRealTimeGaugeMetric

func ConstructRealTimeGaugeMetric(metricSpec *wfv1.Prometheus, valueFunc func() float64) prometheus.Metric

func NewMetricsRegistry

func NewMetricsRegistry(metricsProvider MetricsProvider, informer cache.SharedIndexInformer, disableLegacyMetrics bool) *prometheus.Registry

func NewTelemetryRegistry

func NewTelemetryRegistry() *prometheus.Registry

NewTelemetryRegistry creates a new prometheus registry that collects telemetry

func RunServer

func RunServer(ctx context.Context, config config.PrometheusConfig, registry *prometheus.Registry)

RunServer starts a metrics server

Types

type MetricsProvider

type MetricsProvider interface {
	GetMetrics() map[string]prometheus.Metric
}

type RealTimeMetric

type RealTimeMetric struct {
	Func func() float64
}