Struct DownloadQueue 

pub struct DownloadQueue { /* private fields */ }

Implementations

impl DownloadQueue

pub fn new() -> Arc<Self>

pub fn subscribe(&self) -> Receiver<DownloadEvent>

pub async fn listing(&self) -> DownloadsListing

Returns the current active/queued/history snapshot.

pub async fn enqueue( &self, model: String, ) -> Result<(String, usize, EnqueueOutcome), EnqueueError>

Enqueue a model for download. Returns (job_id, position, outcome). Position 0 means the job will run immediately after the driver wakes; N means N jobs are ahead. Duplicate enqueue returns the existing id.

pub async fn enqueue_recipe( &self, payload: RecipePayload, ) -> Result<(String, usize, EnqueueOutcome), EnqueueError>

Enqueue a recipe-driven download (Civitai single-file checkpoint). Returns (job_id, position, outcome). Dedupes on payload.catalog_id — re-enqueuing the same recipe returns the existing job id so the SPA’s idempotent retry doesn’t double-pull.

Recipe jobs use the catalog id (e.g. cv:618692) as DownloadJob.model so the drawer / API listing show something meaningful. The driver task looks up the recipe payload by job id and dispatches to the recipe driver instead of the manifest driver.

pub async fn enqueue_in_group( &self, model: String, catalog_id: &str, ) -> Result<(String, usize, EnqueueOutcome), EnqueueError>

Enqueue a manifest model and bind the resulting job to a catalog group. Same return shape as Self::enqueue; an AlreadyPresent outcome still registers the existing job into the group, so a catalog-driven enqueue that races with a manual mold pull of the same companion still gets its membership tracked correctly.

pub async fn enqueue_recipe_in_group( &self, payload: RecipePayload, catalog_id: &str, ) -> Result<(String, usize, EnqueueOutcome), EnqueueError>

Recipe-pull variant of Self::enqueue_in_group. Catalog id is taken from the payload, so callers don’t pass it twice.

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

Cancel an in-flight or queued download. Returns true if a job was found and cancelled; false if the id is unknown.