HealthCheckLoop runs periodic health checks on all workers. onCrash is called when a worker crash is detected. onProgress is called with per-session progress data after each successful check. Either callback may be nil.
(ctx context.Context, interval time.Duration, onCrash WorkerCrashHandler, onProgress ProgressHandler)
| 81 | // onProgress is called with per-session progress data after each successful check. |
| 82 | // Either callback may be nil. |
| 83 | HealthCheckLoop(ctx context.Context, interval time.Duration, onCrash WorkerCrashHandler, onProgress ProgressHandler) |
| 84 | |
| 85 | // SetMaxWorkers updates the maximum number of workers. 0 means unlimited. |
| 86 | SetMaxWorkers(n int) |
no outgoing calls