Struct SqliteImageJobStore 

pub struct SqliteImageJobStore { /* private fields */ }

Durable job state used by the HTTP job manager and history index.

Implementations

impl SqliteImageJobStore

pub async fn open(path: &Path) -> Result<Self, BridgeError>

Opens storage and applies idempotent migrations.

pub async fn close(self) -> Result<(), BridgeError>

Closes the SQLite worker after pending calls finish.

pub async fn create( &self, auth_scope: &str, id: &str, request: &ImageRequest, now: u64, max_pending: usize, max_database_bytes: u64, ) -> Result<SqliteJobSubmission, BridgeError>

Inserts a queued request if bounded pending capacity remains.

pub async fn statistics(&self) -> Result<SqliteJobStatistics, BridgeError>

Returns bounded aggregate counters without request, prompt, or path data.

pub async fn recover_interrupted(&self, now: u64) -> Result<usize, BridgeError>

Marks previously running jobs interrupted without retrying paid work.

pub async fn queued_identities( &self, limit: usize, ) -> Result<Vec<(String, String)>, BridgeError>

Returns oldest-first queued identities across ownership scopes for crash recovery.

pub async fn claim( &self, auth_scope: &str, id: &str, now: u64, ) -> Result<bool, BridgeError>

Atomically claims one queued job for execution.

pub async fn progress( &self, auth_scope: &str, id: &str, stage: &str, partial_images: u32, now: u64, ) -> Result<(), BridgeError>

Stores only the latest safe progress label and partial count.

pub async fn succeed( &self, auth_scope: &str, id: &str, response: &ImageResponse, now: u64, ) -> Result<(), BridgeError>

Stores a verified terminal result.

pub async fn fail( &self, auth_scope: &str, id: &str, status: ImageJobStatus, error: &BridgeError, now: u64, ) -> Result<(), BridgeError>

Stores a structured terminal error or cancellation.

pub async fn request_cancel( &self, auth_scope: &str, id: &str, now: u64, ) -> Result<ImageJob, BridgeError>

Durably requests cancellation and immediately cancels queued work.

pub async fn get( &self, auth_scope: &str, id: &str, ) -> Result<ImageJob, BridgeError>

Returns one complete job record.

pub async fn list( &self, auth_scope: &str, filter: ImageJobListFilter, ) -> Result<Vec<ImageJobSummary>, BridgeError>

Lists newest-first summaries using a stable (created,id) cursor.

pub async fn update_history( &self, auth_scope: &str, id: &str, favorite: Option<bool>, deleted: Option<bool>, now: u64, ) -> Result<ImageJob, BridgeError>

Updates favorite and soft-delete gallery state without removing job evidence.

pub async fn prune( &self, now: u64, retention_secs: u64, max_retained: usize, max_retained_bytes: u64, ) -> Result<usize, BridgeError>

Removes terminal records outside time/count retention bounds.

Trait Implementations

impl Debug for SqliteImageJobStore

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

Formats the value using the given formatter.