package metrics

import "sigs.k8s.io/controller-runtime/pkg/internal/metrics"

Index ¶

• Constants
• type DepthMetricWithPriority
• type MetricsProviderWithPriority
• type WorkqueueMetricsProvider
• func (WorkqueueMetricsProvider) NewAddsMetric(name string) workqueue.CounterMetric
• func (WorkqueueMetricsProvider) NewDepthMetric(name string) workqueue.GaugeMetric
• func (WorkqueueMetricsProvider) NewDepthMetricWithPriority(name string) DepthMetricWithPriority
• func (WorkqueueMetricsProvider) NewLatencyMetric(name string) workqueue.HistogramMetric
• func (WorkqueueMetricsProvider) NewLongestRunningProcessorSecondsMetric(name string) workqueue.SettableGaugeMetric
• func (WorkqueueMetricsProvider) NewRetriesMetric(name string) workqueue.CounterMetric
• func (WorkqueueMetricsProvider) NewUnfinishedWorkSecondsMetric(name string) workqueue.SettableGaugeMetric
• func (WorkqueueMetricsProvider) NewWorkDurationMetric(name string) workqueue.HistogramMetric

Constants ¶

const (
	WorkQueueSubsystem         = metrics.WorkQueueSubsystem
	DepthKey                   = metrics.DepthKey
	AddsKey                    = metrics.AddsKey
	QueueLatencyKey            = metrics.QueueLatencyKey
	WorkDurationKey            = metrics.WorkDurationKey
	UnfinishedWorkKey          = metrics.UnfinishedWorkKey
	LongestRunningProcessorKey = metrics.LongestRunningProcessorKey
	RetriesKey                 = metrics.RetriesKey
)

Metrics subsystem and all keys used by the workqueue.

Types ¶

type DepthMetricWithPriority ¶

type DepthMetricWithPriority interface {
	Inc(priority int)
	Dec(priority int)
}

DepthMetricWithPriority represents a depth metric with priority.

type MetricsProviderWithPriority ¶

type MetricsProviderWithPriority interface {
	workqueue.MetricsProvider

	NewDepthMetricWithPriority(name string) DepthMetricWithPriority
}

type WorkqueueMetricsProvider ¶

type WorkqueueMetricsProvider struct{}

func (WorkqueueMetricsProvider) NewAddsMetric ¶

func (WorkqueueMetricsProvider) NewAddsMetric(name string) workqueue.CounterMetric

func (WorkqueueMetricsProvider) NewDepthMetric ¶

func (WorkqueueMetricsProvider) NewDepthMetric(name string) workqueue.GaugeMetric

func (WorkqueueMetricsProvider) NewDepthMetricWithPriority ¶

func (WorkqueueMetricsProvider) NewDepthMetricWithPriority(name string) DepthMetricWithPriority

func (WorkqueueMetricsProvider) NewLatencyMetric ¶

func (WorkqueueMetricsProvider) NewLatencyMetric(name string) workqueue.HistogramMetric

func (WorkqueueMetricsProvider) NewLongestRunningProcessorSecondsMetric ¶

func (WorkqueueMetricsProvider) NewLongestRunningProcessorSecondsMetric(name string) workqueue.SettableGaugeMetric

func (WorkqueueMetricsProvider) NewRetriesMetric ¶

func (WorkqueueMetricsProvider) NewRetriesMetric(name string) workqueue.CounterMetric

func (WorkqueueMetricsProvider) NewUnfinishedWorkSecondsMetric ¶

func (WorkqueueMetricsProvider) NewUnfinishedWorkSecondsMetric(name string) workqueue.SettableGaugeMetric

func (WorkqueueMetricsProvider) NewWorkDurationMetric ¶

func (WorkqueueMetricsProvider) NewWorkDurationMetric(name string) workqueue.HistogramMetric

Source Files ¶

workqueue.go