Struct SqliteQueueBackend 

pub struct SqliteQueueBackend { /* private fields */ }

Durable queue backend using SQLite

Implementations

impl SqliteQueueBackend

pub fn new(pool: SqlitePool) -> Self

Trait Implementations

impl QueueBackend for SqliteQueueBackend

fn enqueue<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, tenant_id: &'life1 str, job_type: &'life2 str, payload: Value, delay_secs: Option<u64>, ) -> Pin<Box<dyn Future<Output = Result<Uuid, QueueError>> + Send + 'async_trait>>

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

Enqueue a job payload for a specific tenant

fn dequeue<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Option<JobEntry>, QueueError>> + Send + 'async_trait>>

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

Pull next available job

fn update_status<'life0, 'async_trait>( &'life0 self, id: Uuid, status: JobStatus, error: Option<String>, delay_secs: Option<u64>, ) -> Pin<Box<dyn Future<Output = Result<(), QueueError>> + Send + 'async_trait>>

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

Update job status (ack/nack) delay_secs is used for retries - how long to wait before the job is available again

fn get_status<'life0, 'life1, 'async_trait>( &'life0 self, tenant_id: &'life1 str, id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<JobStatus, QueueError>> + Send + 'async_trait>>

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

Get job status

fn get_job<'life0, 'life1, 'async_trait>( &'life0 self, tenant_id: &'life1 str, id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<JobEntry, QueueError>> + Send + 'async_trait>>

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

Get full job entry (for polling endpoint)

fn set_result<'life0, 'async_trait>( &'life0 self, id: Uuid, result: Value, ) -> Pin<Box<dyn Future<Output = Result<(), QueueError>> + Send + 'async_trait>>

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

Store the result of a completed job