Struct FileClaimRegistry 

pub struct FileClaimRegistry { /* private fields */ }

Shared registry of file claims for one swarm (or multi-writer) run.

Implementations

impl FileClaimRegistry

pub fn new() -> Self

pub fn set_listener(&self, listener: Option<ConflictListener>)

Install (or replace) the conflict listener.

pub fn claim_key(path: &Path) -> String

Normalize a path for claim keys: absolute, no trailing slash noise.

pub fn try_claim( &self, agent_id: &str, agent_label: &str, path: &Path, ) -> ClaimResult

Try to claim path for agent_id. Same agent re-claim is a no-op success.

pub fn set_stale_listener(&self, listener: Option<StaleListener>)

pub fn note_read(&self, agent_id: &str, path: &Path) -> Option<FileStaleEvent>

Record a read. If another agent wrote since this reader last saw the path, return a stale event (and notify the listener).

pub fn release_agent(&self, agent_id: &str)

Drop every claim held by agent_id (worker finished).

pub fn clear(&self)

Clear all claims (swarm session end).

pub fn snapshot(&self) -> Vec<(String, String)>

Snapshot of current claims (path → owner label), sorted by path.

pub fn len(&self) -> usize

pub fn is_empty(&self) -> bool

Trait Implementations

impl Clone for FileClaimRegistry

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for FileClaimRegistry

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

Formats the value using the given formatter.

impl Default for FileClaimRegistry

fn default() -> Self

Returns the “default value” for a type.