| 284 | } |
| 285 | |
| 286 | func (f *queueMetricsFactory) newQueueMetrics(name string, clock clock.Clock) queueMetrics { |
| 287 | mp := f.metricsProvider |
| 288 | if len(name) == 0 || mp == (noopMetricsProvider{}) { |
| 289 | return noMetrics{} |
| 290 | } |
| 291 | return &defaultQueueMetrics{ |
| 292 | clock: clock, |
| 293 | depth: mp.NewDepthMetric(name), |
| 294 | adds: mp.NewAddsMetric(name), |
| 295 | latency: mp.NewLatencyMetric(name), |
| 296 | workDuration: mp.NewWorkDurationMetric(name), |
| 297 | unfinishedWorkSeconds: mp.NewUnfinishedWorkSecondsMetric(name), |
| 298 | longestRunningProcessor: mp.NewLongestRunningProcessorSecondsMetric(name), |
| 299 | deprecatedDepth: mp.NewDeprecatedDepthMetric(name), |
| 300 | deprecatedAdds: mp.NewDeprecatedAddsMetric(name), |
| 301 | deprecatedLatency: mp.NewDeprecatedLatencyMetric(name), |
| 302 | deprecatedWorkDuration: mp.NewDeprecatedWorkDurationMetric(name), |
| 303 | deprecatedUnfinishedWorkSeconds: mp.NewDeprecatedUnfinishedWorkSecondsMetric(name), |
| 304 | deprecatedLongestRunningProcessor: mp.NewDeprecatedLongestRunningProcessorMicrosecondsMetric(name), |
| 305 | addTimes: map[t]time.Time{}, |
| 306 | processingStartTimes: map[t]time.Time{}, |
| 307 | } |
| 308 | } |
| 309 | |
| 310 | func newRetryMetrics(name string) retryMetrics { |
| 311 | var ret *defaultRetryMetrics |