vector/internal_events/
postgresql_metrics.rs

1use metrics::counter;
2use vector_lib::internal_event::{InternalEvent, error_stage, error_type};
3
4#[derive(Debug)]
5pub struct PostgresqlMetricsCollectError<'a> {
6    pub error: String,
7    pub endpoint: &'a str,
8}
9
10impl InternalEvent for PostgresqlMetricsCollectError<'_> {
11    fn emit(self) {
12        error!(
13            message = "PostgreSQL query error.",
14            error = %self.error,
15            error_type = error_type::REQUEST_FAILED,
16            stage = error_stage::RECEIVING,
17            endpoint = %self.endpoint,
18            internal_log_rate_limit = true,
19        );
20        counter!(
21            "component_errors_total",
22            "error_type" => error_type::REQUEST_FAILED,
23            "stage" => error_stage::RECEIVING,
24        )
25        .increment(1);
26    }
27}