vector/internal_events/
batch.rs

1use metrics::counter;
2use vector_lib::internal_event::InternalEvent;
3use vector_lib::internal_event::{error_stage, error_type, ComponentEventsDropped, UNINTENTIONAL};
4
5#[derive(Debug)]
6pub struct LargeEventDroppedError {
7    pub(crate) length: usize,
8    pub max_length: usize,
9}
10
11impl InternalEvent for LargeEventDroppedError {
12    fn emit(self) {
13        let reason = "Event larger than batch max_bytes.";
14        error!(
15            message = reason,
16            batch_max_bytes = %self.max_length,
17            length = %self.length,
18            error_type = error_type::CONDITION_FAILED,
19            stage = error_stage::SENDING,
20
21        );
22        counter!(
23            "component_errors_total",
24            "error_code" => "oversized",
25            "error_type" => error_type::CONDITION_FAILED,
26            "stage" => error_stage::SENDING,
27        )
28        .increment(1);
29        emit!(ComponentEventsDropped::<UNINTENTIONAL> { count: 1, reason });
30    }
31}
vector/internal_events/batch.rs

vector/internal_events/
batch.rs
