Struct MessageCache 

pub struct MessageCache { /* private fields */ }

Thread-safe message cache with TTL-based eviction.

Messages are stored for a configurable duration to serve Graft requests from nodes that missed the initial broadcast.

Implementations

impl MessageCache

pub fn new(ttl: Duration, max_size: usize) -> Self

Create a new message cache with the specified TTL and max size.

pub fn insert(&self, id: MessageId, payload: Bytes)

Insert a message into the cache.

If the message already exists, this is a no-op. If the cache is full, oldest entries are evicted.

pub fn get(&self, id: &MessageId) -> Option<Arc<Bytes>>

Get a message from the cache.

Returns None if the message is not in the cache or has expired. Returns a cloned Arc to avoid holding locks during message sending.

pub fn contains(&self, id: &MessageId) -> bool

Check if a message exists in the cache (without returning it).

pub fn get_many(&self, ids: &[MessageId]) -> HashMap<MessageId, Arc<Bytes>>

Get multiple messages from the cache.

Returns a map of found message IDs to their payloads.

pub fn remove(&self, id: &MessageId) -> Option<Arc<Bytes>>

Remove a message from the cache.

pub fn len(&self) -> usize

Get the number of entries currently in the cache.

pub fn is_empty(&self) -> bool

Check if the cache is empty.

pub fn evict_expired(&self)

Remove all expired entries from the cache.

pub fn clear(&self)

Clear all entries from the cache.

pub fn stats(&self) -> CacheStats

Get cache statistics.

Trait Implementations

impl Debug for MessageCache

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

Formats the value using the given formatter.

impl Default for MessageCache

fn default() -> Self

Returns the “default value” for a type.