Struct Dedupe 

pub struct Dedupe { /* private fields */ }

A bounded set of recently-seen msg_ids. Its main job is collapsing the bus’s at-least-once redelivery (the same message seen twice before it’s acked), which is a near-term window, so a bounded LRU suffices. It is not sized to cover the full MAX_PAST_MS window: a replay older than this capacity but still within the past bound could slip through — an accepted tradeoff under the signed, trusted-tailnet threat model, in exchange for durable delivery to offline/slow peers.

Implementations

impl Dedupe

pub fn new(cap: usize) -> Self

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

Record id. Returns false if it was already present (a replay).