Struct DedupEngine 

pub struct DedupEngine { /* private fields */ }

Local signature deduplication engine.

Wraps an ExceptionBuffer to provide:

• Duplicate detection by signature
• Distinct signature counting
• Pending (unreported) batch extraction

Implementations

impl DedupEngine

pub fn new(buffer: Arc<ExceptionBuffer>) -> Self

Create a new dedup engine wrapping the given buffer.

pub fn is_duplicate(&self, signature: &str) -> bool

Check whether the given signature already exists in the buffer.

pub fn distinct_count(&self) -> usize

Return the number of distinct signatures in the buffer.

pub fn pending_batch(&self) -> Vec<ExceptionRecord>

Return all unreported sample records from the buffer.

Trait Implementations

impl Debug for DedupEngine

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

Formats the value using the given formatter.