Struct MlJobQueue 

pub struct MlJobQueue { /* private fields */ }

Queue + worker pool pair. Safe to clone — every clone shares the underlying queue via Arc.

Implementations

impl MlJobQueue

pub fn start(worker_count: usize, worker_fn: MlWorkFn) -> Self

Spin up a queue with worker_count threads. worker_fn is invoked once per job. No durable backend — see Self::start_with_backend for the persisted variant.

pub fn start_with_backend( worker_count: usize, worker_fn: MlWorkFn, backend: Arc<dyn MlPersistence>, ) -> Self

Spin up a queue that persists every state transition to backend. On startup the queue rehydrates any non-terminal records and re-enqueues them (they were Running when the previous process died — treat as Queued on resume).

pub fn submit( &self, kind: MlJobKind, target_name: impl Into<String>, spec_json: impl Into<String>, ) -> MlJobId

Enqueue a new job. Returns the assigned id so the caller can poll status later.

pub fn get(&self, id: MlJobId) -> Option<MlJob>

Fetch a job by id.

pub fn list(&self) -> Vec<MlJob>

Snapshot every job (terminal + live). Callers use this to back SELECT * FROM ML_JOBS.

pub fn cancel(&self, id: MlJobId) -> bool

Request cooperative cancellation. Returns true if the job was still cancellable, false if it had already reached a terminal state or does not exist.

pub fn shutdown(&self)

Stop every worker thread after they finish their current job. Pending jobs are left in the queue — a future process start would pick them up once persistence is wired.

Trait Implementations

impl Clone for MlJobQueue

fn clone(&self) -> MlJobQueue

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for MlJobQueue

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.