dnstap_parser/
internal_events.rs

1use tracing::warn;
2use vector_lib::internal_event::InternalEvent;
3use vector_lib::internal_event::{error_stage, error_type};
4
5#[derive(Debug)]
6pub(crate) struct DnstapParseWarning<E> {
7    pub error: E,
8}
9
10impl<E: std::fmt::Display> InternalEvent for DnstapParseWarning<E> {
11    fn emit(self) {
12        warn!(
13            message = "Recoverable error occurred while parsing dnstap data.",
14            error = %self.error,
15            stage = error_stage::PROCESSING,
16            error_type = error_type::PARSER_FAILED,
17            internal_log_rate_limit = true,
18        );
19    }
20}