vector/internal_events/
dedupe.rs

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