vector/internal_events/
host_metrics.rs

1use metrics::counter;
2use vector_lib::NamedInternalEvent;
3use vector_lib::internal_event::{InternalEvent, error_stage, error_type};
4
5#[derive(Debug, NamedInternalEvent)]
6pub struct HostMetricsScrapeError {
7    pub message: &'static str,
8}
9
10impl InternalEvent for HostMetricsScrapeError {
11    fn emit(self) {
12        error!(
13            message = self.message,
14            error_type = error_type::READER_FAILED,
15            stage = error_stage::RECEIVING,
16        );
17
18        counter!(
19            "component_errors_total",
20            "error_type" => error_type::READER_FAILED,
21            "stage" => error_stage::RECEIVING,
22        )
23        .increment(1);
24    }
25}
26
27#[derive(Debug, NamedInternalEvent)]
28pub struct HostMetricsScrapeDetailError<E> {
29    pub message: &'static str,
30    pub error: E,
31}
32
33impl<E: std::fmt::Display> InternalEvent for HostMetricsScrapeDetailError<E> {
34    fn emit(self) {
35        error!(
36            message = self.message,
37            error = %self.error,
38            error_type = error_type::READER_FAILED,
39            stage = error_stage::RECEIVING,
40        );
41
42        counter!(
43            "component_errors_total",
44            "error_type" => error_type::READER_FAILED,
45            "stage" => error_stage::RECEIVING,
46        )
47        .increment(1);
48    }
49}
50
51#[derive(Debug, NamedInternalEvent)]
52pub struct HostMetricsScrapeFilesystemError {
53    pub message: &'static str,
54    pub error: heim::Error,
55    pub mount_point: String,
56}
57
58impl InternalEvent for HostMetricsScrapeFilesystemError {
59    fn emit(self) {
60        error!(
61            message = self.message,
62            mount_point = self.mount_point,
63            error = %self.error,
64            error_type = error_type::READER_FAILED,
65            stage = error_stage::RECEIVING,
66        );
67
68        counter!(
69            "component_errors_total",
70            "error_type" => error_type::READER_FAILED,
71            "stage" => error_stage::RECEIVING,
72        )
73        .increment(1);
74    }
75}
vector/internal_events/host_metrics.rs

vector/internal_events/
host_metrics.rs
