Struct LocalClaimTracker 

pub struct LocalClaimTracker { /* private fields */ }

Thread-safe, lock-free tracker for symbol-level claims across sessions.

Key insight: two sessions modifying DIFFERENT symbols in the same file is NOT a conflict. Only same-symbol modifications across sessions are TRUE conflicts. This is dkod’s core differentiator over line-based VCS.

The tracker is keyed by (repo_id, file_path) and stores a Vec<SymbolClaim> for each file. DashMap provides fine-grained per-shard locking so reads are effectively lock-free when not contending on the same shard.

Implementations

impl LocalClaimTracker

pub fn new() -> Self

Trait Implementations

impl ClaimTracker for LocalClaimTracker

fn record_claim<'life0, 'life1, 'async_trait>( &'life0 self, repo_id: Uuid, file_path: &'life1 str, claim: SymbolClaim, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Record a symbol claim (non-blocking — does not reject on conflict).

fn acquire_lock<'life0, 'life1, 'async_trait>( &'life0 self, repo_id: Uuid, file_path: &'life1 str, claim: SymbolClaim, ) -> Pin<Box<dyn Future<Output = Result<AcquireOutcome, SymbolLocked>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Attempt to acquire a symbol lock. Returns Err(SymbolLocked) if another session already holds the symbol.

fn release_lock<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, repo_id: Uuid, file_path: &'life1 str, session_id: Uuid, qualified_name: &'life2 str, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Release a single symbol lock for a session in a specific file.

fn release_locks<'life0, 'async_trait>( &'life0 self, repo_id: Uuid, session_id: Uuid, ) -> Pin<Box<dyn Future<Output = Vec<ReleasedLock>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Release all locks held by a session for a specific repo.

fn check_conflicts<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, repo_id: Uuid, file_path: &'life1 str, session_id: Uuid, qualified_names: &'life2 [String], ) -> Pin<Box<dyn Future<Output = Vec<ConflictInfo>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Check whether any of the given symbols conflict with another session.

fn get_all_conflicts_for_session<'life0, 'async_trait>( &'life0 self, repo_id: Uuid, session_id: Uuid, ) -> Pin<Box<dyn Future<Output = Vec<(String, ConflictInfo)>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Return all conflicts for a session across all file paths.

fn clear_session<'life0, 'async_trait>( &'life0 self, session_id: Uuid, ) -> Pin<Box<dyn Future<Output = Vec<ReleasedLock>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Remove all claims belonging to a session across ALL repos.

impl Default for LocalClaimTracker

fn default() -> Self

Returns the “default value” for a type.