Documentation
¶
Index ¶
- Constants
- Variables
- type Metrics
- func (m *Metrics) NewAddsMetric(queueName string) workqueue.CounterMetric
- func (m *Metrics) NewDepthMetric(queueName string) workqueue.GaugeMetric
- func (m *Metrics) NewLatencyMetric(queueName string) workqueue.HistogramMetric
- func (m *Metrics) NewLongestRunningProcessorSecondsMetric(queueName string) workqueue.SettableGaugeMetric
- func (m *Metrics) NewRetriesMetric(queueName string) workqueue.CounterMetric
- func (m *Metrics) NewUnfinishedWorkSecondsMetric(queueName string) workqueue.SettableGaugeMetric
- func (m *Metrics) NewWorkDurationMetric(queueName string) workqueue.HistogramMetric
Constants ¶
View Source
const (
// LabelQueueName denotes which queue the metric is for
LabelQueueName = "queue_name"
)
Variables ¶
View Source
var Cell = cell.Module( "workqueue-metrics-provider", "Metrics provider for client-go workqueues", metrics.Metric(NewMetrics), cell.Provide(func(m *Metrics) workqueue.MetricsProvider { return m }), )
Functions ¶
This section is empty.
Types ¶
type Metrics ¶
type Metrics struct {
WorkQueueDepth metric.Vec[metric.Gauge]
WorkQueueAddsTotal metric.Vec[metric.Counter]
WorkQueueLatency metric.Vec[metric.Observer]
WorkQueueDuration metric.Vec[metric.Observer]
WorkQueueUnfinishedWork metric.Vec[metric.Gauge]
WorkQueueLongestRunningProcessor metric.Vec[metric.Gauge]
WorkQueueRetries metric.Vec[metric.Counter]
}
Metrics implements the workqueue.MetricsProvider interface
func NewMetrics ¶
func NewMetrics() *Metrics
func (*Metrics) NewAddsMetric ¶
func (m *Metrics) NewAddsMetric(queueName string) workqueue.CounterMetric
func (*Metrics) NewDepthMetric ¶
func (m *Metrics) NewDepthMetric(queueName string) workqueue.GaugeMetric
func (*Metrics) NewLatencyMetric ¶
func (m *Metrics) NewLatencyMetric(queueName string) workqueue.HistogramMetric
func (*Metrics) NewLongestRunningProcessorSecondsMetric ¶
func (m *Metrics) NewLongestRunningProcessorSecondsMetric(queueName string) workqueue.SettableGaugeMetric
func (*Metrics) NewRetriesMetric ¶
func (m *Metrics) NewRetriesMetric(queueName string) workqueue.CounterMetric
func (*Metrics) NewUnfinishedWorkSecondsMetric ¶
func (m *Metrics) NewUnfinishedWorkSecondsMetric(queueName string) workqueue.SettableGaugeMetric
func (*Metrics) NewWorkDurationMetric ¶
func (m *Metrics) NewWorkDurationMetric(queueName string) workqueue.HistogramMetric
Source Files
Click to show internal directories.
Click to hide internal directories.