Struct MemoryJobQueue 

pub struct MemoryJobQueue { /* private fields */ }

In-process JobQueue impl.

Implementations

impl MemoryJobQueue

pub fn new(pubsub: Arc<MemoryPubsub>, kv: Arc<MemoryKv>) -> Self

Build atop the supplied pubsub (for DLQ routing) and KV (for dedup-CAS).

Trait Implementations

impl JobQueue for MemoryJobQueue

fn enqueue<'life0, 'life1, 'async_trait>( &'life0 self, queue: &'life1 str, job: Job, ) -> Pin<Box<dyn Future<Output = Result<JobId, BusError>> + Send + 'async_trait>>

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

Enqueue a job. Returns a stable id.

fn claim<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, queue: &'life1 str, _worker_id: &'life2 str, lease_ttl: Duration, ) -> Pin<Box<dyn Future<Output = Result<Option<ClaimedJob>, BusError>> + Send + 'async_trait>>

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

Claim the next available job. Returns None when the queue is empty. Implementations may long-poll up to a small bounded duration before returning None.