Struct PostgresTaskQueue 

pub struct PostgresTaskQueue { /* private fields */ }

Postgres-backed queue implementation.

Implementations

impl PostgresTaskQueue

pub fn new(database_url: &str) -> Result<Self, QueueError>

Create a queue backed by a lazily-connected PgPool.

pub fn from_pool(pool: PgPool) -> Self

Construct from an existing pool.

pub fn pool(&self) -> &PgPool

Access the underlying pool.

Trait Implementations

impl Clone for PostgresTaskQueue

fn clone(&self) -> PostgresTaskQueue

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PostgresTaskQueue

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

Formats the value using the given formatter.

impl TaskQueue for PostgresTaskQueue

fn enqueue( &self, task_id: TaskId, run_id: RunId, priority: u32, command_class: CommandClass, available_at: Option<DateTime<Utc>>, ) -> Result<Uuid, QueueError>

Enqueue a task for scheduling.

fn claim( &self, request: &ClaimRequest, config: &ConcurrencyConfig, ) -> Result<Vec<QueueEntry>, QueueError>

Claim up to limit pending tasks, ordered by priority DESC (with aging).

fn heartbeat( &self, queue_id: Uuid, worker_id: &str, lease_ttl: Duration, ) -> Result<(), QueueError>

Extend the lease for an active entry (heartbeat).

fn complete(&self, queue_id: Uuid, worker_id: &str) -> Result<(), QueueError>

Mark a leased entry as completed. Only the lease owner can complete.

fn fail(&self, queue_id: Uuid, worker_id: &str) -> Result<(), QueueError>

Mark a leased entry as failed. Only the lease owner can fail.

fn override_priority( &self, task_id: TaskId, priority: u32, ) -> Result<(), QueueError>

Update priority for all entries for a task.

fn cancel(&self, queue_id: Uuid) -> Result<(), QueueError>

Override priority for all known entries belonging to a task.

fn reclaim_stale(&self, grace_period: Duration) -> Result<usize, QueueError>

Reclaim stale leases: entries where lease_expires_at + grace < now.

fn stats(&self) -> QueueStats

Return the number of entries in each status.

fn entries(&self) -> Vec<QueueEntry>

Return a snapshot of all known queue entries.

fn leased_count_for_run(&self, run_id: RunId) -> usize

Return the number of currently leased entries for a given run.

fn leased_count_for_class(&self, class: CommandClass) -> usize

Return the number of currently leased entries for a given command class.

fn pending_count(&self) -> usize

Return total pending entries.

fn cancel_for_run(&self, run_id: RunId) -> Result<usize, QueueError>

Cancel all pending and leased entries for a given run.

fn cancel_stale_runs( &self, active_run_ids: &[RunId], ) -> Result<usize, QueueError>

Cancel all pending and leased entries NOT belonging to the given set of run IDs.