Struct DedupStore 

pub struct DedupStore { /* private fields */ }

In-memory replay-detection store. Single-process only; SPEC §10.2 notes that a multi-worker deployment needs a shared backing store.

check_and_mark returns Ok(()) if the bytes are new in the window, and Err(ReplayDetected) if they’ve been seen.

Implementations

impl DedupStore

pub fn new(window_secs: u64) -> Self

Construct a new store with the given replay-window duration in seconds.

pub fn check_and_mark(&self, canonical_bytes: &[u8]) -> Result<(), Error>

Returns Ok(()) if canonical_bytes is new in the window; stores it. Returns Err(ReplayDetected) if the same bytes were already accepted within window_secs. Garbage-collects expired entries on every call.

pub fn reset(&self)

Test helper — clears the store.

Trait Implementations

impl Default for DedupStore

fn default() -> Self

Returns the “default value” for a type.