Struct QueueHandle 

pub struct QueueHandle { /* private fields */ }

Implementations

impl QueueHandle

pub fn new(driver: Arc<dyn QueueDriver>, registry: JobRegistry) -> Self

pub fn in_memory(_pool: PgPool) -> Self

Build an in-memory queue. Works for any driver — pool ignored. The _pool parameter is kept for ergonomics: many call sites already have a pool handy, no need to omit the argument at every call.

pub fn in_memory_no_pool() -> Self

In-memory queue without requiring a pool reference. Useful for tests and for MySQL/SQLite apps where there’s no PG pool to pass.

pub fn database(pool: PgPool) -> Self

Database-backed queue. Postgres-only in v0.1 (uses SKIP LOCKED). MySQL + SQLite database queue drivers are deferred to v0.2.

pub fn fake() -> (Self, Arc<Mutex<Vec<QueuePayload>>>)

pub fn registry(&self) -> &JobRegistry

pub async fn push(&self, payload: QueuePayload) -> Result<(), Error>

pub async fn pop(&self, queue: &str) -> Result<Option<QueuePayload>, Error>

pub async fn fail( &self, payload: QueuePayload, error: String, ) -> Result<(), Error>

Trait Implementations

impl Clone for QueueHandle

fn clone(&self) -> QueueHandle

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.