Struct InMemoryTaskQueue 

pub struct InMemoryTaskQueue { /* private fields */ }

Thread-safe in-memory task queue.

Implementations

impl InMemoryTaskQueue

pub fn new() -> Self

Trait Implementations

impl Default for InMemoryTaskQueue

fn default() -> Self

Returns the “default value” for a type.

impl TaskQueue for InMemoryTaskQueue

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 entries(&self) -> Vec<QueueEntry>

Return a snapshot of all known queue entries.

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 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.