Struct SeenMessageCache 

pub struct SeenMessageCache { /* private fields */ }

Cache of seen message IDs for deduplication

Tracks message IDs with TTL expiration to prevent infinite relay loops while allowing legitimate re-transmissions.

Implementations

impl SeenMessageCache

pub fn new() -> Self

Create a new cache with default TTL

pub fn with_ttl(ttl_ms: u64) -> Self

Create with custom TTL

pub fn has_seen(&self, message_id: &MessageId) -> bool

Check if a message has been seen before

Returns true if the message was already seen (should not process/relay). Returns false if this is a new message (should process).

pub fn mark_seen( &mut self, message_id: MessageId, origin: NodeId, now_ms: u64, ) -> bool

Mark a message as seen

Returns true if this is a new message (first time seen). Returns false if we’ve seen this message before.

pub fn check_and_mark( &mut self, message_id: MessageId, origin: NodeId, now_ms: u64, ) -> bool

Check and mark in one operation

Returns true if this is a new message that should be processed. Returns false if the message was already seen (duplicate).

pub fn cleanup(&mut self, now_ms: u64)

Remove expired entries

pub fn len(&self) -> usize

Get the number of entries in the cache

pub fn is_empty(&self) -> bool

Check if the cache is empty

pub fn clear(&mut self)

Clear all entries

pub fn get_stats(&self, message_id: &MessageId) -> Option<(u64, u32, NodeId)>

Get statistics about a message

Trait Implementations

impl Debug for SeenMessageCache

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

Formats the value using the given formatter.

impl Default for SeenMessageCache

Available on crate feature std only.

fn default() -> Self

Returns the “default value” for a type.