Struct QueueRepository 

pub struct QueueRepository { /* private fields */ }

Queue repository for push/pop operations using SKIP LOCKED

Implementations

impl QueueRepository

pub fn new(pool: PgPool) -> Self

pub async fn push<T: Serialize>( &self, queue: &QueueName, payload: &T, ) -> Result<i64>

Push a job to the queue

pub async fn pop<T: DeserializeOwned>( &self, queue: &QueueName, ) -> Result<Option<Job<T>>>

Pop a job from the queue using SKIP LOCKED for concurrent safety. Returns None if no pending jobs are available.

pub async fn complete(&self, queue: &QueueName, job_id: i64) -> Result<()>

Mark a job as completed

pub async fn fail(&self, queue: &QueueName, job_id: i64) -> Result<()>

Mark a job as failed, resetting it to pending for retry

pub async fn pending_count(&self, queue: &QueueName) -> Result<i64>

Get the count of pending jobs in a queue

Trait Implementations

impl Clone for QueueRepository

fn clone(&self) -> QueueRepository

Returns a duplicate of the value.

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

Performs copy-assignment from source.