pub struct DeduplicatorConfig {
pub max_tracked_messages: usize,
pub retention_time_secs: u64,
pub use_bloom_filter: bool,
pub bloom_filter_bits: usize,
pub bloom_hash_count: usize,
pub bloom_filter_count: usize,
pub bloom_rotation_secs: u64,
}Expand description
Configuration for deduplication.
Fields§
§max_tracked_messages: usizeMaximum number of message IDs to track (used for HashMap fallback).
retention_time_secs: u64Time to keep message IDs in memory (seconds).
use_bloom_filter: boolEnable bloom filter mode for scalable deduplication.
bloom_filter_bits: usizeNumber of bits in each bloom filter (default: 2^20 = ~1MB per filter).
bloom_hash_count: usizeNumber of hash functions for bloom filter (default: 7 for ~1% false positive).
bloom_filter_count: usizeNumber of rotating bloom filters (default: 4 for hourly windows).
bloom_rotation_secs: u64Rotation interval in seconds (default: 900 = 15 minutes).
Trait Implementations§
Source§impl Clone for DeduplicatorConfig
impl Clone for DeduplicatorConfig
Source§fn clone(&self) -> DeduplicatorConfig
fn clone(&self) -> DeduplicatorConfig
Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreSource§impl Debug for DeduplicatorConfig
impl Debug for DeduplicatorConfig
Source§impl Default for DeduplicatorConfig
impl Default for DeduplicatorConfig
Source§fn default() -> DeduplicatorConfig
fn default() -> DeduplicatorConfig
Returns the “default value” for a type. Read more
Auto Trait Implementations§
impl Freeze for DeduplicatorConfig
impl RefUnwindSafe for DeduplicatorConfig
impl Send for DeduplicatorConfig
impl Sync for DeduplicatorConfig
impl Unpin for DeduplicatorConfig
impl UnsafeUnpin for DeduplicatorConfig
impl UnwindSafe for DeduplicatorConfig
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<T> Declassify for T
impl<T> Declassify for T
type Declassified = T
fn declassify(self) -> T
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
Source§fn in_current_span(self) -> Instrumented<Self> ⓘ
fn in_current_span(self) -> Instrumented<Self> ⓘ
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more