Struct MemQueueBackend 

pub struct MemQueueBackend { /* private fields */ }

Process-local queue backend (not durable).

When to use: Mode 1 embedded apps, CI, and unit tests. Not for Mode 2 remote workers — another process cannot see this memory. Prefer SqliteQueueBackend or PostgresQueueBackend when processes share a queue.

Getting started: Mode 1.

Thread-safe via RwLock.

Implementations

impl MemQueueBackend

pub fn new() -> MemQueueBackend

New empty backend.

Examples

Wire into Boson::builder (feature mem on the boson facade):

use std::sync::Arc;

use boson_backend_mem::MemQueueBackend;
use boson_core::QueueBackend;

let backend: Arc<dyn QueueBackend> = Arc::new(MemQueueBackend::new());
let _ = backend;

Full boot with Boson: Boson::builder().queue_backend(Arc::new(MemQueueBackend::new()))….

Trait Implementations

impl Debug for MemQueueBackend

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

Formats the value using the given formatter.

impl Default for MemQueueBackend

fn default() -> MemQueueBackend

Returns the “default value” for a type.

impl QueueBackend for MemQueueBackend

fn upsert_job<'life0, 'life1, 'async_trait>( &'life0 self, job: &'life1 Job, ) -> Pin<Box<dyn Future<Output = Result<(), BosonError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, MemQueueBackend: 'async_trait,

Persist or update a job row.

fn enqueue_with_policies<'life0, 'life1, 'async_trait>( &'life0 self, job: Job, task_config: &'life1 TaskConfig, ) -> Pin<Box<dyn Future<Output = Result<(String, JobEnqueueDisposition), BosonError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, MemQueueBackend: 'async_trait,

Insert job with idempotency semantics (see trait-level contract).

fn get_job<'life0, 'life1, 'async_trait>( &'life0 self, job_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<Job>, BosonError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, MemQueueBackend: 'async_trait,

Load one job by id.

fn list_jobs<'life0, 'async_trait>( &'life0 self, status_filter: Option<JobStatus>, offset: usize, limit: usize, ) -> Pin<Box<dyn Future<Output = Result<Vec<Job>, BosonError>> + Send + 'async_trait>>

where 'life0: 'async_trait, MemQueueBackend: 'async_trait,

List jobs with optional status filter and pagination.

fn cancel_job_if_active<'life0, 'life1, 'async_trait>( &'life0 self, job_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), BosonError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, MemQueueBackend: 'async_trait,

Cancel a job if it is still active (queued or running).

fn try_claim_job<'life0, 'life1, 'async_trait>( &'life0 self, job_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<Job>, BosonError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, MemQueueBackend: 'async_trait,

Atomically claim a queued job for execution.

fn revert_job_to_queued<'life0, 'life1, 'async_trait>( &'life0 self, job_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), BosonError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, MemQueueBackend: 'async_trait,

Revert a job to queued (retry path).

fn distinct_pools_queued<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>, BosonError>> + Send + 'async_trait>>

where 'life0: 'async_trait, MemQueueBackend: 'async_trait,

Distinct pool names with queued jobs.

fn list_queued_for_pool_sorted<'life0, 'life1, 'async_trait>( &'life0 self, pool: &'life1 str, limit: usize, ) -> Pin<Box<dyn Future<Output = Result<Vec<Job>, BosonError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, MemQueueBackend: 'async_trait,

Queued jobs for one pool, sorted by priority then created time.

fn pop_claim_from_pool<'life0, 'life1, 'async_trait>( &'life0 self, pool: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<Job>, BosonError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, MemQueueBackend: 'async_trait,

Atomically claim the highest-priority queued job from pool when supported.

fn count_jobs<'life0, 'async_trait>( &'life0 self, status_filter: Option<JobStatus>, ) -> Pin<Box<dyn Future<Output = Result<u64, BosonError>> + Send + 'async_trait>>

where 'life0: 'async_trait, MemQueueBackend: 'async_trait,

Count jobs, optionally filtered by status.

fn count_jobs_for_task<'life0, 'life1, 'async_trait>( &'life0 self, task_name: &'life1 str, status: Option<JobStatus>, ) -> Pin<Box<dyn Future<Output = Result<u64, BosonError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, MemQueueBackend: 'async_trait,

Count jobs for one task, optionally filtered by status.

fn count_active_jobs_for_task<'life0, 'life1, 'async_trait>( &'life0 self, task_name: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<u32, BosonError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, MemQueueBackend: 'async_trait,

Count active (queued + running) jobs for rate-limit checks.

fn find_nonterminal_by_idempotency_key<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<String>, BosonError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, MemQueueBackend: 'async_trait,

Find non-terminal job by idempotency key.

fn upsert_run<'life0, 'life1, 'async_trait>( &'life0 self, run: &'life1 Run, ) -> Pin<Box<dyn Future<Output = Result<(), BosonError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, MemQueueBackend: 'async_trait,

Persist or update a run row.

fn get_run<'life0, 'life1, 'async_trait>( &'life0 self, run_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<Run>, BosonError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, MemQueueBackend: 'async_trait,

Load one run by id.

fn list_runs<'life0, 'life1, 'async_trait>( &'life0 self, job_id_filter: Option<&'life1 str>, offset: usize, limit: usize, ) -> Pin<Box<dyn Future<Output = Result<Vec<Run>, BosonError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, MemQueueBackend: 'async_trait,

List runs with optional job filter and pagination.

fn finish_run<'life0, 'life1, 'async_trait>( &'life0 self, run_id: &'life1 str, status: RunStatus, duration_ms: Option<i64>, error_message: Option<String>, ) -> Pin<Box<dyn Future<Output = Result<(), BosonError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, MemQueueBackend: 'async_trait,

Mark a run terminal with outcome fields.

fn count_runs<'life0, 'life1, 'async_trait>( &'life0 self, job_id_filter: Option<&'life1 str>, ) -> Pin<Box<dyn Future<Output = Result<u64, BosonError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, MemQueueBackend: 'async_trait,

Count runs, optionally filtered by job id.

fn count_runs_since<'life0, 'async_trait>( &'life0 self, since: DateTime<Utc>, ) -> Pin<Box<dyn Future<Output = Result<u64, BosonError>> + Send + 'async_trait>>

where 'life0: 'async_trait, MemQueueBackend: 'async_trait,

Count runs with started_at >= since.

fn task_run_stats<'life0, 'life1, 'async_trait>( &'life0 self, task_name: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<TaskRunStats, BosonError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, MemQueueBackend: 'async_trait,

Aggregate run totals for one task.

fn get_task_config<'life0, 'life1, 'async_trait>( &'life0 self, task_name: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<TaskConfig>, BosonError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, MemQueueBackend: 'async_trait,

Load task config by name.

fn upsert_task_config<'life0, 'life1, 'async_trait>( &'life0 self, config: &'life1 TaskConfig, ) -> Pin<Box<dyn Future<Output = Result<(), BosonError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, MemQueueBackend: 'async_trait,

Persist task config.

fn try_claim_run_lease<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, job_id: &'life1 str, worker_id: &'life2 str, ttl_secs: i64, ) -> Pin<Box<dyn Future<Output = Result<Option<String>, BosonError>> + Send + 'async_trait>>

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

Attempt to claim a run lease for job_id (stored as lease task id).

fn extend_lease<'life0, 'life1, 'async_trait>( &'life0 self, lease_id: &'life1 str, ttl_secs: i64, ) -> Pin<Box<dyn Future<Output = Result<(), BosonError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, MemQueueBackend: 'async_trait,

Extend lease TTL for a held lease.

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

where 'life0: 'async_trait, 'life1: 'async_trait, MemQueueBackend: 'async_trait,

Release a held lease.

fn expired_lease_job_pairs<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<(String, String)>, BosonError>> + Send + 'async_trait>>

where 'life0: 'async_trait, MemQueueBackend: 'async_trait,

Expired leases as (lease_record_id, job_id).