Struct MemoryBackend

pub struct MemoryBackend { /* private fields */ }

In-memory queue backend

Implementations

impl MemoryBackend

pub fn new(config: QueueConfig) -> Self

Create a new memory backend

Trait Implementations

impl QueueBackend for MemoryBackend

fn requeue_job<'life0, 'async_trait>( &'life0 self, job_id: JobId, _job: JobEntry, ) -> Pin<Box<dyn Future<Output = QueueResult<bool>> + Send + 'async_trait>>

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

Atomic requeue implementation for memory backend

fn clear_jobs_by_state<'life0, 'async_trait>( &'life0 self, state: JobState, ) -> Pin<Box<dyn Future<Output = QueueResult<u64>> + Send + 'async_trait>>

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

Atomic clear jobs by state implementation for memory backend

fn enqueue<'life0, 'async_trait>( &'life0 self, job: JobEntry, ) -> Pin<Box<dyn Future<Output = QueueResult<JobId>> + Send + 'async_trait>>

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

Enqueue a job

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

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

Dequeue the next available job

fn complete<'life0, 'async_trait>( &'life0 self, job_id: JobId, result: JobResult<()>, ) -> Pin<Box<dyn Future<Output = QueueResult<()>> + Send + 'async_trait>>

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

Mark a job as completed

fn get_job<'life0, 'async_trait>( &'life0 self, job_id: JobId, ) -> Pin<Box<dyn Future<Output = QueueResult<Option<JobEntry>>> + Send + 'async_trait>>

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

Get job by ID

fn get_jobs_by_state<'life0, 'async_trait>( &'life0 self, state: JobState, limit: Option<usize>, ) -> Pin<Box<dyn Future<Output = QueueResult<Vec<JobEntry>>> + Send + 'async_trait>>

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

Get jobs by state

fn remove_job<'life0, 'async_trait>( &'life0 self, job_id: JobId, ) -> Pin<Box<dyn Future<Output = QueueResult<bool>> + Send + 'async_trait>>

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

Remove a job from the queue

fn clear<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = QueueResult<()>> + Send + 'async_trait>>

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

Clear all jobs from the queue

fn stats<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = QueueResult<QueueStats>> + Send + 'async_trait>>

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

Get queue statistics