Struct SymbolClaimTracker 

pub struct SymbolClaimTracker { /* 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 SymbolClaimTracker

pub fn new() -> Self

Create a new, empty tracker.

pub fn record_claim(&self, repo_id: Uuid, file_path: &str, claim: SymbolClaim)

Record a symbol claim. If the same session already claims the same qualified_name in the same file, the existing claim is updated (not duplicated).

pub fn acquire_lock( &self, repo_id: Uuid, file_path: &str, claim: SymbolClaim, ) -> Result<AcquireOutcome, SymbolLocked>

Attempt to acquire a symbol lock. If the symbol is already claimed by another session, returns Err(SymbolLocked) — the write MUST NOT proceed. If claimed by the same session, or unclaimed, acquires and returns Ok(()).

This is the blocking counterpart to record_claim. Use this when writes should be rejected if another agent holds the symbol.

pub fn release_lock( &self, repo_id: Uuid, file_path: &str, session_id: Uuid, qualified_name: &str, )

Release a single symbol lock for a session in a specific file. Used to roll back partially-acquired locks when a batch fails.

pub fn release_locks( &self, repo_id: Uuid, session_id: Uuid, ) -> Vec<ReleasedLock>

Release all locks held by a session and return what was released. Callers should emit symbol.lock.released events for each returned entry.

pub fn check_conflicts( &self, repo_id: Uuid, file_path: &str, session_id: Uuid, qualified_names: &[String], ) -> Vec<ConflictInfo>

Check whether any of the given qualified_names are already claimed by a session other than session_id. Returns a ConflictInfo for each conflicting symbol.

pub fn get_all_conflicts_for_session( &self, repo_id: Uuid, session_id: Uuid, ) -> Vec<(String, ConflictInfo)>

Return all conflicts for a given session across ALL file paths.

This checks every tracked file to find symbols where session_id has a claim AND another session also claims the same symbol.

pub fn clear_session(&self, session_id: Uuid) -> Vec<ReleasedLock>

Remove all claims belonging to a session across ALL repos (e.g. on disconnect or GC). Returns the released locks so callers can emit symbol.lock.released events to unblock waiting agents.

Trait Implementations

impl Default for SymbolClaimTracker

fn default() -> Self

Returns the “default value” for a type.