vector/internal_events/
aggregate.rs

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