Function registerWorkDequeued

pkg/workerpool/observability.go:158–161

(name string, start time.Time)

}

func registerWorkDequeued(name string, start time.Time) {
	poolMetrics.workQueueSize.WithLabelValues(name).Dec()
	poolMetrics.queueLatency.WithLabelValues(name).Observe(time.Since(start).Seconds())
}

func registerWorkProcessed(ctx context.Context, name string) {
	poolMetrics.workProcessed.WithLabelValues(ctx, name).Inc()