Struct DedupFilter 

pub struct DedupFilter { /* private fields */ }

Time-bounded deduplication filter.

Tracks recently seen IDs and automatically expires entries older than the configured TTL. Uses an injectable Clock (WEFT-113) so tests can advance TTL without sleeping.

Implementations

impl DedupFilter

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

Create a new dedup filter with the given TTL and max capacity.

Binds the production RealClock.

pub fn with_clock( ttl: Duration, max_entries: usize, clock: Arc<dyn Clock>, ) -> Self

Create a dedup filter with an injectable Clock.

pub fn default_mesh() -> Self

Create a dedup filter with default settings (60s TTL, 10000 entries).

pub fn check_and_insert(&mut self, id: &str) -> bool

Check if an ID has been seen before. If not, mark it as seen. Returns true if this is a new (not duplicate) message.

pub fn is_duplicate(&self, id: &str) -> bool

Check if an ID has been seen (without inserting).

pub fn len(&self) -> usize

Number of tracked IDs.

pub fn is_empty(&self) -> bool

Whether the filter is empty.