Struct JobExecutor 

pub struct JobExecutor { /* private fields */ }

Implementations

impl JobExecutor

pub fn new( backends: Vec<DiscoveredBackend>, max_concurrent: u32, out_tx: Sender<Message>, ) -> Self

pub fn queue_depth(&self) -> u32

Number of currently-executing jobs. Useful for heartbeat reporting.

pub async fn dispatch(&self, job: Job)

Accept a job from the WSS read loop and spawn its driver task.

Never blocks the caller: capacity violations and unknown models are signalled to the coordinator via job_error and the function returns immediately.

pub async fn cancel(&self, job_id: Uuid)

Cancel a job in response to a coordinator job_cancel. Aborts the driver task and removes the entry. The terminal frame the driver was going to send is suppressed by the abort.