Struct TaskQueue 

pub struct TaskQueue { /* private fields */ }

Cloneable task facade sharing the pool’s single state lock.

Implementations

impl TaskQueue

pub fn new() -> Self

pub fn with_limits(limits: DistributedLimits) -> Result<Self, DistributedError>

pub fn enqueue( &self, expected_revision: u64, now_secs: u64, spec: TaskSpec, ) -> Result<Transition<ScanTask>, DistributedError>

Admit one fresh task at an exact coordinator revision.

pub fn peek_next(&self) -> Result<Option<ScanTask>, DistributedError>

Peek without consuming or mutating the task record.

pub fn get_task( &self, task_id: &str, ) -> Result<Option<ScanTask>, DistributedError>

pub fn tasks(&self) -> Result<Vec<ScanTask>, DistributedError>

Return tasks in stable task-ID order.

pub fn snapshot(&self) -> Result<StateSnapshot, DistributedError>

Trait Implementations

impl Clone for TaskQueue

fn clone(&self) -> TaskQueue

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for TaskQueue

fn default() -> Self

Returns the “default value” for a type.