vector/internal_events/
dedupe.rs

1use vector_lib::internal_event::{ComponentEventsDropped, InternalEvent, INTENTIONAL};
2
3#[derive(Debug)]
4pub struct DedupeEventsDropped {
5    pub count: usize,
6}
7
8impl InternalEvent for DedupeEventsDropped {
9    fn emit(self) {
10        emit!(ComponentEventsDropped::<INTENTIONAL> {
11            count: self.count,
12            reason: "Events have been found in cache for deduplication.",
13        });
14    }
15}