Struct SqliteJobStore 

pub struct SqliteJobStore { /* private fields */ }

SQLite-backed job store implementing every job port.

Implementations

impl SqliteJobStore

pub const fn new(pool: SqlitePool) -> Self

pub async fn enqueue_in( &self, transaction: &mut Transaction<'_, Sqlite>, record: JobRecord, ) -> Result<EnqueueOutcome, JobError>

Insert the job and its first publication generation inside the caller’s transaction so the business mutation and the durable dispatch commit atomically.

pub async fn ingest_in( &self, transaction: &mut Transaction<'_, Sqlite>, record: JobRecord, ) -> Result<IngestOutcome, JobError>

Insert the job with its publication recorded as already delivered (Scheduler ingestion) inside the caller’s transaction.

Trait Implementations

impl Clone for SqliteJobStore

fn clone(&self) -> SqliteJobStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SqliteJobStore

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

Formats the value using the given formatter.

impl JobPublicationStore for SqliteJobStore

fn claim_due<'life0, 'life1, 'async_trait>( &'life0 self, worker_execution_id: &'life1 str, limit: usize, claim_expires_at: DateTime<Utc>, now: DateTime<Utc>, ) -> Pin<Box<dyn Future<Output = Result<Vec<JobPublication>, JobError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Atomically claim up to limit due publications. The returned publications carry the claim’s lease identity.

fn mark_published<'life0, 'async_trait>( &'life0 self, publication_id: Uuid, lease_id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<(), JobError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Mark one publication delivered, fenced by its lease.

fn mark_failed<'life0, 'life1, 'async_trait>( &'life0 self, publication_id: Uuid, lease_id: Uuid, error: &'life1 str, retry_at: DateTime<Utc>, ) -> Pin<Box<dyn Future<Output = Result<(), JobError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Record a failed transport send with a retry time, fenced by the publication lease.

fn recover_expired_claims<'life0, 'async_trait>( &'life0 self, now: DateTime<Utc>, ) -> Pin<Box<dyn Future<Output = Result<usize, JobError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Reset expired publication claims to pending. Returns the count.

impl JobStore for SqliteJobStore

fn enqueue_with_intent<'life0, 'async_trait>( &'life0 self, record: JobRecord, ) -> Pin<Box<dyn Future<Output = Result<EnqueueOutcome, JobError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Atomically insert the job and its first pending publication generation. SQL adapters additionally expose enqueue_in to share the caller’s transaction.

fn ingest_existing_delivery<'life0, 'async_trait>( &'life0 self, record: JobRecord, ) -> Pin<Box<dyn Future<Output = Result<IngestOutcome, JobError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Atomically ingest a delivery that already exists on the transport (Scheduler occurrences): create the job with its publication marked delivered, or locate the existing occurrence, without ever inserting a pending publication.

fn claim_execution<'life0, 'life1, 'async_trait>( &'life0 self, job_id: Uuid, worker_execution_id: &'life1 str, lease_expires_at: DateTime<Utc>, now: DateTime<Utc>, ) -> Pin<Box<dyn Future<Output = Result<Option<JobClaim>, JobError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Atomically claim the execution lease for one delivery. The worker_execution_id must be unique per invocation (not a static worker name); the returned claim’s opaque lease_id is the sole mutation authority. Returns None when the job is missing, already leased, not yet available or terminal.

fn complete<'life0, 'life1, 'async_trait>( &'life0 self, claim: &'life1 JobClaim, now: DateTime<Utc>, ) -> Pin<Box<dyn Future<Output = Result<(), JobError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Record terminal success and release the lease, fenced by the claim.

fn schedule_retry_and_publish<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, claim: &'life1 JobClaim, failure_code: &'life2 str, next_available_at: DateTime<Utc>, now: DateTime<Utc>, ) -> Pin<Box<dyn Future<Output = Result<Uuid, JobError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Atomically record a retryable failure: verify the claim fence, append the attempt, return the job to pending at the next availability time, clear the execution lease and insert the next pending publication generation — all in one transaction, so no intermediate committed state can strand the job.

fn fail_permanently<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, claim: &'life1 JobClaim, failure_code: &'life2 str, now: DateTime<Utc>, ) -> Pin<Box<dyn Future<Output = Result<(), JobError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Record terminal failure and release the lease, fenced by the claim.

fn cancel<'life0, 'async_trait>( &'life0 self, job_id: Uuid, expected_revision: u64, now: DateTime<Utc>, ) -> Pin<Box<dyn Future<Output = Result<(), JobError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Operator-guarded cancellation of a non-running job.

fn retry_failed<'life0, 'async_trait>( &'life0 self, job_id: Uuid, expected_revision: u64, now: DateTime<Utc>, ) -> Pin<Box<dyn Future<Output = Result<DateTime<Utc>, JobError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Operator-guarded retry of a permanently failed job: back to pending at a fresh revision with a new pending publication generation, atomically.

fn recover_expired_leases<'life0, 'async_trait>( &'life0 self, now: DateTime<Utc>, ) -> Pin<Box<dyn Future<Output = Result<usize, JobError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Reset expired running leases back to pending and open a pending publication generation for each recovered job. Returns the number recovered.

fn get<'life0, 'async_trait>( &'life0 self, job_id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<Option<JobRecord>, JobError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn list_failed<'life0, 'async_trait>( &'life0 self, limit: usize, ) -> Pin<Box<dyn Future<Output = Result<Vec<JobRecord>, JobError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Bounded listing of permanently failed jobs for operators.

impl OverlapLockStore for SqliteJobStore

fn acquire<'life0, 'life1, 'async_trait>( &'life0 self, overlap_key: &'life1 str, lease_id: Uuid, expires_at: DateTime<Utc>, now: DateTime<Utc>, ) -> Pin<Box<dyn Future<Output = Result<bool, JobError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Acquire the lock for lease_id until expires_at; false when held.

fn refresh<'life0, 'life1, 'async_trait>( &'life0 self, overlap_key: &'life1 str, lease_id: Uuid, expires_at: DateTime<Utc>, now: DateTime<Utc>, ) -> Pin<Box<dyn Future<Output = Result<bool, JobError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Extend a held lock; false when the caller no longer owns it.

fn release<'life0, 'life1, 'async_trait>( &'life0 self, overlap_key: &'life1 str, lease_id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<(), JobError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Release a held lock. Releasing an unheld lock is a no-op; releasing another owner’s lock is impossible by construction.

fn recover_expired<'life0, 'async_trait>( &'life0 self, now: DateTime<Utc>, ) -> Pin<Box<dyn Future<Output = Result<usize, JobError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Delete expired locks. Returns the number removed.