type queueMetrics … type GaugeMetric … type SettableGaugeMetric … type CounterMetric … type SummaryMetric … type HistogramMetric … type noopMetric … func (noopMetric) Inc() { … } func (noopMetric) Dec() { … } func (noopMetric) Set(float64) { … } func (noopMetric) Observe(float64) { … } type defaultQueueMetrics … func (m *defaultQueueMetrics[T]) add(item T) { … } func (m *defaultQueueMetrics[T]) get(item T) { … } func (m *defaultQueueMetrics[T]) done(item T) { … } func (m *defaultQueueMetrics[T]) updateUnfinishedWork() { … } type noMetrics … func (noMetrics[T]) add(item T) { … } func (noMetrics[T]) get(item T) { … } func (noMetrics[T]) done(item T) { … } func (noMetrics[T]) updateUnfinishedWork() { … } // Gets the time since the specified start in seconds. func (m *defaultQueueMetrics[T]) sinceInSeconds(start time.Time) float64 { … } type retryMetrics … type defaultRetryMetrics … func (m *defaultRetryMetrics) retry() { … } type MetricsProvider … type noopMetricsProvider … func (_ noopMetricsProvider) NewDepthMetric(name string) GaugeMetric { … } func (_ noopMetricsProvider) NewAddsMetric(name string) CounterMetric { … } func (_ noopMetricsProvider) NewLatencyMetric(name string) HistogramMetric { … } func (_ noopMetricsProvider) NewWorkDurationMetric(name string) HistogramMetric { … } func (_ noopMetricsProvider) NewUnfinishedWorkSecondsMetric(name string) SettableGaugeMetric { … } func (_ noopMetricsProvider) NewLongestRunningProcessorSecondsMetric(name string) SettableGaugeMetric { … } func (_ noopMetricsProvider) NewRetriesMetric(name string) CounterMetric { … } var globalMetricsProvider … var setGlobalMetricsProviderOnce … func newQueueMetrics[T comparable](mp MetricsProvider, name string, clock clock.Clock) queueMetrics[T] { … } func newRetryMetrics(name string, provider MetricsProvider) retryMetrics { … } // SetProvider sets the metrics provider for all subsequently created work // queues. Only the first call has an effect. func SetProvider(metricsProvider MetricsProvider) { … }
Codebase Browser
kubernetes