(it *contextualItem[T])
| 85 | } |
| 86 | |
| 87 | func (wp *workerPool[T]) handle(it *contextualItem[T]) { |
| 88 | registerWorkerBusy(wp.Name) |
| 89 | defer registerWorkerIdle(wp.Name) |
| 90 | defer registerWorkProcessed(it.ctx, wp.Name) |
| 91 | defer registerWorkLatency(wp.Name, time.Now()) |
| 92 | wp.Handler(it.ctx, it.item) |
| 93 | } |
| 94 | |
| 95 | func (wp *workerPool[T]) workerBody(initialWork *contextualItem[T]) func(context.Context) error { |
| 96 | worker := func(ctx context.Context) error { |
no test coverage detected