Struct Deduplicator 

pub struct Deduplicator { /* private fields */ }

Deduplicates requests by key within a TTL window.

Guarantees

• Deterministic: same key always maps to the same result
• Thread-safe via Arc<Mutex<_>>
• Entries expire after ttl

Implementations

impl Deduplicator

pub fn new(ttl: Duration) -> Self

Create a new deduplicator with the given TTL.

pub fn check_and_register( &self, key: &str, ) -> Result<DeduplicationResult, AgentRuntimeError>

Check whether key is new, cached, or in-flight.

Marks the key as in-flight if it is new.

pub fn check( &self, key: &str, ttl: Duration, ) -> Result<DeduplicationResult, AgentRuntimeError>

Check deduplication state for a key with a per-call TTL override.

Marks the key as in-flight if it is new. Ignores the stored TTL and uses ttl instead for expiry checks.

pub fn dedup_many( &self, requests: &[(&str, Duration)], ) -> Result<Vec<DeduplicationResult>, AgentRuntimeError>

Check deduplication state for multiple keys at once.

Returns results in the same order as requests. Each entry is (key, ttl) — same signature as check.

pub fn complete( &self, key: &str, result: impl Into<String>, ) -> Result<(), AgentRuntimeError>

Complete a request: move from in-flight to cached with the given result.

pub fn fail(&self, key: &str) -> Result<(), AgentRuntimeError>

Remove a key from in-flight tracking without caching a result.

Call this when an in-flight operation fails so that subsequent callers are not permanently blocked by a stuck InProgress entry for the full TTL.

Trait Implementations

impl Clone for Deduplicator

fn clone(&self) -> Deduplicator

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Deduplicator

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.