Function registerWorkProcessed

pkg/workerpool/observability.go:163–165

(ctx context.Context, name string)

}

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

func registerWorkDropped(ctx context.Context, name string) {
	poolMetrics.workDropped.WithLabelValues(ctx, name).Inc()