vector_common/internal_event/
component_events_timed_out.rs

1use metrics::{Counter, counter};
2
3use super::Count;
4
5crate::registered_event! {
6    ComponentEventsTimedOut {
7        reason: &'static str,
8    } => {
9        timed_out_events: Counter = counter!("component_timed_out_events_total"),
10        timed_out_requests: Counter = counter!("component_timed_out_requests_total"),
11        reason: &'static str = self.reason,
12    }
13
14    fn emit(&self, data: Count) {
15        warn!(
16            message = "Events timed out",
17            events = data.0,
18            reason = self.reason,
19        );
20        self.timed_out_events.increment(data.0 as u64);
21        self.timed_out_requests.increment(1);
22    }
23}