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 complete( &self, key: &str, result: impl Into<String>, ) -> Result<(), AgentRuntimeError>

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

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.