vector_common/internal_event/
component_events_timed_out.rs

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