Struct DeduplicationCache 

pub struct DeduplicationCache {
    seen: HashMap<u64, Instant>,
    order: VecDeque<(u64, Instant)>,
    config: DeduplicationConfig,
    duplicates_detected: u64,
    total_checked: u64,
}

Deduplication cache for K2K message processing.

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

Fields

seen: HashMap<u64, Instant>

order: VecDeque<(u64, Instant)>

config: DeduplicationConfig

duplicates_detected: u64

total_checked: u64

Implementations

impl DeduplicationCache

pub fn new(config: DeduplicationConfig) -> DeduplicationCache

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.