Struct MemoryDocketBackend 

pub struct MemoryDocketBackend { /* private fields */ }

In-memory Docket backend for testing and development.

Tasks are stored in memory and not persisted across restarts. This backend is thread-safe and suitable for single-process deployments.

Implementations

impl MemoryDocketBackend

pub fn new(settings: DocketSettings) -> Self

Creates a new memory backend.

Trait Implementations

impl DocketBackend for MemoryDocketBackend

fn enqueue(&self, task: DocketTask) -> DocketResult<()>

Enqueues a task for processing.

fn dequeue(&self, task_types: &[String]) -> DocketResult<Option<DocketTask>>

Dequeues a task for the given task types.

fn ack(&self, task_id: &TaskId, result: Value) -> DocketResult<()>

Acknowledges successful task completion.

fn nack(&self, task_id: &TaskId, error: &str) -> DocketResult<()>

Negative acknowledgement - task failed, may be retried.

fn get_task(&self, task_id: &TaskId) -> DocketResult<Option<DocketTask>>

Gets task by ID.

fn list_tasks( &self, status: Option<TaskStatus>, limit: usize, ) -> DocketResult<Vec<DocketTask>>

Lists tasks, optionally filtered by status.

fn cancel(&self, task_id: &TaskId, reason: Option<&str>) -> DocketResult<()>

Cancels a task.

fn stats(&self) -> DocketResult<QueueStats>

Returns queue statistics.

fn requeue_stale(&self) -> DocketResult<usize>

Requeues tasks that have exceeded visibility timeout.