Struct LocalJobScheduler 

pub struct LocalJobScheduler { /* private fields */ }

Implementations

impl LocalJobScheduler

pub fn new() -> Self

pub fn global() -> Arc<Self>

pub fn spawn_global_worker_with_runtime(runtime: Handle)

Spawn the background worker that processes queued jobs. The worker must run on a Tokio runtime; pass a Handle when calling from outside a runtime context (e.g. from a Tauri setup callback, which runs synchronously and is NOT inside tokio::spawn’s implicit runtime). When called from within a runtime context, None falls back to tokio::spawn.

pub fn spawn_global_worker(runtime: Option<Handle>)

Spawn the background worker. Uses tokio::spawn — only call this from within a Tokio runtime context. For callers outside a runtime (e.g. Tauri’s setup hook), use [spawn_global_worker_with_runtime] with an explicit handle.

pub fn enqueue(&self, kind: LocalJobKind) -> Result<LocalJob, String>

pub fn update_job_meta(&self, updated: &LocalJob) -> Result<(), String>

Patch provenance fields on an existing job (e.g. after fleet accept).

pub fn enqueue_for_device( &self, kind: LocalJobKind, target_device_id: Option<String>, ) -> Result<LocalJob, String>

Enqueue work for a specific apparatus. None / local device_id runs here. Remote registered devices are delivered via the fleet job path (HTTP + outbox).

pub fn snapshot(&self) -> Result<JobQueueSnapshot, String>

pub fn get(&self, id: &str) -> Result<Option<LocalJob>, String>

pub fn cancel(&self, id: &str) -> Result<bool, String>

pub fn retry(&self, id: &str) -> Result<LocalJob, String>

Re-enqueue a completed, failed, or cancelled job with the same bounded inputs.

pub fn clear_finished(&self) -> Result<usize, String>

Remove finished history while preserving queued and running work.

pub fn report_progress( &self, id: &str, progress: f64, message: impl Into<String>, ) -> Result<(), String>

Update visible progress for a running job. Progress is clamped and persisted so recovery and agent diagnostics see the same state as the UI.

Trait Implementations

impl Clone for LocalJobScheduler

fn clone(&self) -> LocalJobScheduler

Returns a duplicate of the value.

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

Performs copy-assignment from source.