Struct WorkerPool 

pub struct WorkerPool { /* private fields */ }

Long-lived worker pool that services all active download jobs.

Implementations

impl WorkerPool

pub fn new( servers: Arc<Mutex<Vec<ServerConfig>>>, bandwidth: Arc<BandwidthLimiter>, conn_tracker: Arc<ConnectionTracker>, stall_timeout_secs: u64, ) -> Arc<Self>

pub fn set_max_worker_idle(&self, d: Duration)

Override the worker idle eviction threshold. Tests use this to make the supervisor’s heartbeat check converge in seconds.

pub fn max_worker_idle(&self) -> Duration

Read current worker idle eviction threshold.

pub fn eviction_count(&self) -> u64

Lifetime count of worker evictions performed by the heartbeat watchdog. Increases by 1 each time the supervisor reclaims a stalled worker. Test harnesses use this as a positive signal that the Phase 5 idle watchdog actually fired.

pub fn start(self: &Arc<Self>)

Spawn workers for all currently enabled servers and start the supervisor task. Call once at queue-manager startup.

pub fn reconcile_servers(self: &Arc<Self>)

Create or tear down workers to match the current server list.

For each enabled server, ensures exactly server.connections workers exist. Extra workers (from a shrunk limit or disabled server) have their per-worker shutdown flag flipped so they exit gracefully after the current article.

pub fn pause_job(&self, job_id: &str)

Pause a job: workers stop pulling its items, and any item currently being held while paused is returned to the queue.

pub fn resume_job(&self, job_id: &str)

Resume a paused job.

pub fn abort_job(&self, job_id: &str, reason: String)

Abort a job with a reason. Drains queued items, sets the abort flag, and emits JobAborted via the job’s progress channel.

pub fn cancel_job(&self, job_id: &str)

Cancel a job silently (no JobFinished / JobAborted emission). Used by remove_job when the user deletes a job from the queue — the progress receiver is about to be dropped anyway.

pub async fn shutdown(self: &Arc<Self>)

Shut down all workers gracefully. In-flight articles finish first.

pub fn conn_tracker(&self) -> &Arc<ConnectionTracker>

pub fn has_job(&self, job_id: &str) -> bool

Whether this job still has an active context in the pool.