Skip to main content

vector/internal_events/
metric_to_log.rs

1use serde_json::Error;
2use vector_lib::internal_event::{
3    ComponentEventsDropped, CounterName, InternalEvent, UNINTENTIONAL, error_stage, error_type,
4};
5use vector_lib::{NamedInternalEvent, counter};
6
7#[derive(Debug, NamedInternalEvent)]
8pub struct MetricToLogSerializeError {
9    pub error: Error,
10}
11
12impl InternalEvent for MetricToLogSerializeError {
13    fn emit(self) {
14        let reason = "Metric failed to serialize as JSON.";
15        error!(
16            message = reason,
17            error = ?self.error,
18            error_type = error_type::ENCODER_FAILED,
19            stage = error_stage::PROCESSING
20        );
21        counter!(
22            CounterName::ComponentErrorsTotal,
23            "error_type" => error_type::ENCODER_FAILED,
24            "stage" => error_stage::PROCESSING,
25        )
26        .increment(1);
27
28        emit!(ComponentEventsDropped::<UNINTENTIONAL> { count: 1, reason })
29    }
30}