vector/internal_events/
remap.rs

1use metrics::counter;
2use vector_lib::NamedInternalEvent;
3use vector_lib::internal_event::{
4    ComponentEventsDropped, INTENTIONAL, InternalEvent, UNINTENTIONAL, error_stage, error_type,
5};
6
7#[derive(Debug, NamedInternalEvent)]
8pub struct RemapMappingError {
9    /// If set to true, the remap transform has dropped the event after a failed
10    /// mapping. This internal event reflects that in its messaging.
11    pub event_dropped: bool,
12    pub error: String,
13}
14
15impl InternalEvent for RemapMappingError {
16    fn emit(self) {
17        error!(
18            message = "Mapping failed with event.",
19            error = ?self.error,
20            error_type = error_type::CONVERSION_FAILED,
21            stage = error_stage::PROCESSING,
22        );
23        counter!(
24            "component_errors_total",
25            "error_type" => error_type::CONVERSION_FAILED,
26            "stage" => error_stage::PROCESSING,
27        )
28        .increment(1);
29        if self.event_dropped {
30            emit!(ComponentEventsDropped::<UNINTENTIONAL> {
31                count: 1,
32                reason: "Mapping failed with event.",
33            });
34        }
35    }
36}
37
38#[derive(Debug, NamedInternalEvent)]
39pub struct RemapMappingAbort {
40    /// If set to true, the remap transform has dropped the event after an abort
41    /// during mapping. This internal event reflects that in its messaging.
42    pub event_dropped: bool,
43}
44
45impl InternalEvent for RemapMappingAbort {
46    fn emit(self) {
47        debug!("Event mapping aborted.");
48
49        if self.event_dropped {
50            emit!(ComponentEventsDropped::<INTENTIONAL> {
51                count: 1,
52                reason: "Event mapping aborted.",
53            });
54        }
55    }
56}
vector/internal_events/remap.rs

vector/internal_events/
remap.rs
