Struct HotContext 

pub struct HotContext { /* private fields */ }

Hot context with lock-free concurrent access

Uses DashMap with sequential IDs for lock-free recent updates storage. Older updates are automatically evicted when capacity is reached.

Implementations

impl HotContext

pub fn new(max_size: usize) -> HotContext

Create new hot context with specified capacity

pub fn push(&self, update: ContextUpdate)

Push new update, evicting oldest if at capacity (lock-free)

Uses Release ordering to ensure the insert is visible before the ID increment is visible to readers using Acquire ordering.

pub fn get_recent(&self, n: usize) -> Vec<ContextUpdate>

Get N most recent updates (lock-free)

Note: In a concurrent environment, some entries may have been evicted between loading the ID and fetching. This is expected lock-free behavior. The returned Vec may contain fewer than N elements.

pub fn get_all(&self) -> Vec<ContextUpdate>

Get all updates as Vec in chronological order (lock-free)

Returns updates sorted by insertion order (oldest first). Only iterates over the valid range of IDs to avoid O(n) iteration.

pub fn len(&self) -> usize

Get current length (lock-free)

pub fn is_empty(&self) -> bool

Check if empty (lock-free)

pub fn clear(&self)

Clear all updates (lock-free)

pub fn remove_by_id(&self, entry_id: &Uuid) -> bool

Remove the first update whose ContextUpdate.id matches entry_id (lock-free). Returns true if an entry was removed. Used by manage_entity delete_update so MCP clients can clean up ghost / bad context rows by entry_id.

pub fn back(&self) -> Option<ContextUpdate>

Get most recent update (lock-free)

Returns None if the context is empty or if the most recent entry was evicted by a concurrent push operation.

pub fn snapshot(&self) -> Vec<ContextUpdate>

Get snapshot of all updates as Vec (lock-free) Returns owned Vec for maximum flexibility (.iter(), .rev(), .par_iter(), etc.)

pub fn iter(&self) -> Vec<ContextUpdate>

Iterate over all updates (convenience method, returns Vec)

pub fn to_deque(&self) -> VecDeque<ContextUpdate>

Convert to VecDeque for serialization Only iterates over the valid range of IDs (last max_size entries)

pub fn from_deque(deque: VecDeque<ContextUpdate>, max_size: usize) -> HotContext

Create from VecDeque for deserialization (lock-free)

Trait Implementations

impl Debug for HotContext

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

Formats the value using the given formatter.