Struct DeduplicationCache 

pub struct DeduplicationCache { /* private fields */ }

Deduplication cache for K2K message processing.

Tracks recently-seen message IDs to prevent duplicate processing. Uses a bounded LRU-style eviction with TTL expiry.

Implementations

impl DeduplicationCache

pub fn new(config: DeduplicationConfig) -> Self

Create a new deduplication cache.

pub fn is_duplicate(&mut self, idempotency_key: u64) -> bool

Check if a message ID is a duplicate. If not, records it.

Returns true if this message was already seen (duplicate). Returns false if this is the first time (not duplicate, now recorded).

pub fn was_seen(&self, idempotency_key: u64) -> bool

Check if a key was seen without recording it.

pub fn len(&self) -> usize

Number of entries in the cache.

pub fn is_empty(&self) -> bool

Check if empty.

pub fn clear(&mut self)

Clear the cache.

pub fn metrics(&self) -> DeduplicationMetrics

Get deduplication metrics.