Struct ClaimSet 

pub struct ClaimSet { /* private fields */ }

Exclusive in-process ownership of one spool entry’s relay.

Why: both ingest and the sweep can reach the same entry path. A claim held for the duration of the relay makes “someone is already relaying this” a checkable fact rather than a timing hope. What: a shared HashSet<PathBuf>. Locks are held only across the insert or remove, never across an await.

In-process only, and deliberately so: two console processes sharing one spool directory would still double-relay. That is out of scope here because console is a singleton per data directory, and the target-side delivery_id dedup step 4 owes is the real cross-process answer.

Test: claim_set_refuses_a_second_claim_on_the_same_path, claim_set_releases_on_drop_even_when_the_holder_panics.

Implementations

impl ClaimSet

pub fn new() -> Self

A fresh, empty claim set.

pub fn claim(&self, path: &Path) -> Option<Claim>

Take exclusive ownership of path, or None if someone already has it.

The returned guard releases on drop, including on panic and on an early ? return, so a failed relay cannot leave an entry permanently claimed.

Test: claim_set_refuses_a_second_claim_on_the_same_path.

pub fn len(&self) -> usize

How many entries are claimed right now. Diagnostics and tests only.

pub fn is_empty(&self) -> bool

Whether nothing is claimed.

Trait Implementations

impl Clone for ClaimSet

fn clone(&self) -> ClaimSet

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ClaimSet

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

Formats the value using the given formatter.

impl Default for ClaimSet

fn default() -> ClaimSet

Returns the “default value” for a type.