Struct MirrorQueue 

pub struct MirrorQueue(/* private fields */);

The queue: one worker, one sync at a time, FIFO, deduplicated by repository.

A named type over JobQueue<Mirror> rather than an alias, so Mirror.Sync’s door keeps speaking in orders instead of making every caller reach for the generic.

Implementations

impl MirrorQueue

pub fn new(run: MirrorRunner) -> Self

A queue over run. No thread is started until something is enqueued.

pub fn enqueue(&self, order: MirrorOrder) -> MirrorJob

Ask for order.path to be synced, and return without syncing it.

Returns the job now responsible for the repository: a new one, or the one that was already queued or running. Never enqueues a second sync for a repository that has one live — a double-clicked button would otherwise pull the same pack over somebody else’s network twice.

pub fn status(&self, path: &str) -> Option<MirrorJob>

The job the queue is holding for path, if it still has one.

pub fn peak_in_flight(&self) -> usize

The highest number of syncs that have ever been running together.

Must be 1 after any amount of traffic. 0 before anything has run.

pub fn runs(&self) -> u64

How many times the runner has been called — i.e. how many syncs actually happened. The applied output the dedup gate asserts on.

pub fn stop(&self)

Stop the worker after the job it is on.

Trait Implementations

impl Clone for MirrorQueue

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.