internal/formation/health.go
internal/formation · 17 lines · 1 declarations · source
Declarations
method Worker.heartbeat
func (w *Worker) heartbeat(ctx context.Context, db pg.HealthExecutor, formed, failed int64)
The driver installs reporting before it starts. Direct worker users may omit it. This runs on the actual processing path; no independent timer can mask a blocked drain.