Struct DedupQueue 

pub struct DedupQueue { /* private fields */ }

Priority queue for dedup tasks.

Implementations

impl DedupQueue

pub fn new() -> Self

Create a new empty dedup queue.

pub fn enqueue( &mut self, priority: DedupPriority, kind: DedupTaskKind, target: String, ) -> u64

Enqueue a task, returning the assigned ID.

pub fn enqueue_task(&mut self, task: DedupTask)

Enqueue a pre-built task.

pub fn dequeue(&mut self) -> Option<DedupTask>

Dequeue the highest-priority task.

pub fn peek(&self) -> Option<&DedupTask>

Peek at the highest-priority task without removing it.

pub fn len(&self) -> usize

Get the number of pending tasks.

pub fn is_empty(&self) -> bool

Check if the queue is empty.

pub fn record_completed(&mut self)

Record a task completion.

pub fn record_failed(&mut self)

Record a task failure.

pub fn stats(&self) -> QueueStats

Get queue statistics.

pub fn clear(&mut self)

Clear all pending tasks.

pub fn drain_batch(&mut self, n: usize) -> Vec<DedupTask>

Drain up to n tasks from the queue.

Trait Implementations

impl Debug for DedupQueue

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

Formats the value using the given formatter.

impl Default for DedupQueue

fn default() -> Self

Returns the “default value” for a type.