vector/internal_events/
aggregate.rs

1use metrics::counter;
2use vector_lib::NamedInternalEvent;
3use vector_lib::internal_event::InternalEvent;
4
5#[derive(Debug, NamedInternalEvent)]
6pub struct AggregateEventRecorded;
7
8impl InternalEvent for AggregateEventRecorded {
9    fn emit(self) {
10        counter!("aggregate_events_recorded_total").increment(1);
11    }
12}
13
14#[derive(Debug, NamedInternalEvent)]
15pub struct AggregateFlushed;
16
17impl InternalEvent for AggregateFlushed {
18    fn emit(self) {
19        counter!("aggregate_flushes_total").increment(1);
20    }
21}
22
23#[derive(Debug, NamedInternalEvent)]
24pub struct AggregateUpdateFailed;
25
26impl InternalEvent for AggregateUpdateFailed {
27    fn emit(self) {
28        counter!("aggregate_failed_updates").increment(1);
29    }
30}