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