Struct ConcurrentPathTrie 

pub struct ConcurrentPathTrie { /* private fields */ }

Concurrent Path Trie with lock-free reads and epoch-based reclamation

This trie supports:

• Lock-free concurrent reads via DashMap
• Concurrent inserts with fine-grained locking
• Epoch-based garbage collection for safe memory reclamation

Performance

• Read: O(|path|) with no locking (DashMap provides lock-free reads)
• Insert: O(|path|) with minimal lock contention
• Memory reclamation: Deferred until no readers access old nodes

Implementations

impl ConcurrentPathTrie

pub fn new() -> Self

Create a new empty concurrent trie

pub fn current_epoch(&self) -> u64

Get current epoch

pub fn advance_epoch(&self) -> u64

Advance epoch (call periodically to allow GC)

pub fn begin_read(&self) -> ReadGuard<'_>

Begin a read operation (returns epoch guard) The guard must be held for the duration of the read

pub fn insert(&self, path: &str, column_type: ColumnType) -> ColumnId

Insert a path and get its column ID (thread-safe)

Path format: “users.profile.settings.theme” Returns the assigned column ID

pub fn resolve(&self, path: &str) -> Option<ColumnId>

Resolve a path to its column ID in O(|path|) time (lock-free)

Returns None if path doesn’t exist

pub fn resolve_with_type(&self, path: &str) -> Option<(ColumnId, ColumnType)>

Resolve with type information (lock-free)

pub fn prefix_match(&self, prefix: &str) -> Vec<(String, ColumnId)>

Get all paths that start with a prefix (lock-free)

pub fn total_columns(&self) -> u32

Get total number of columns

pub fn total_nodes(&self) -> usize

Get total number of nodes (memory usage indicator)

pub fn update_min_reader_epoch(&self)

Update minimum reader epoch (call after readers complete)

pub fn min_reader_epoch(&self) -> u64

Get minimum reader epoch (nodes older than this can be reclaimed)

Trait Implementations

impl Debug for ConcurrentPathTrie

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

Formats the value using the given formatter.

impl Default for ConcurrentPathTrie

fn default() -> Self

Returns the “default value” for a type.

impl Send for ConcurrentPathTrie

impl Sync for ConcurrentPathTrie