| 82 | func (n nullMetrics) DequeuedRequest() {} |
| 83 | |
| 84 | type PrometheusMetrics struct { |
| 85 | registry prometheus.Registerer |
| 86 | totalThreads prometheus.Counter |
| 87 | busyThreads prometheus.Gauge |
| 88 | totalWorkers *prometheus.GaugeVec |
| 89 | busyWorkers *prometheus.GaugeVec |
| 90 | readyWorkers *prometheus.GaugeVec |
| 91 | workerCrashes *prometheus.CounterVec |
| 92 | workerRestarts *prometheus.CounterVec |
| 93 | workerRequestTime *prometheus.CounterVec |
| 94 | workerRequestCount *prometheus.CounterVec |
| 95 | workerQueueDepth *prometheus.GaugeVec |
| 96 | queueDepth prometheus.Gauge |
| 97 | mu sync.RWMutex |
| 98 | } |
| 99 | |
| 100 | func (m *PrometheusMetrics) StartWorker(name string) { |
| 101 | m.mu.RLock() |
nothing calls this directly
no outgoing calls
no test coverage detected