diff --git a/crates/audit/src/archiver.rs b/crates/audit/src/archiver.rs index 832e7ff..80f038a 100644 --- a/crates/audit/src/archiver.rs +++ b/crates/audit/src/archiver.rs @@ -69,6 +69,7 @@ where let archive_start = Instant::now(); if let Err(e) = writer.archive_event(event).await { error!(error = %e, "Failed to write event"); + metrics.failed_archive_tasks.increment(1); } else { metrics .archive_event_duration diff --git a/crates/audit/src/metrics.rs b/crates/audit/src/metrics.rs index fd09eaa..906de8e 100644 --- a/crates/audit/src/metrics.rs +++ b/crates/audit/src/metrics.rs @@ -48,4 +48,8 @@ pub struct Metrics { /// Number of in-flight archive tasks. #[metric(describe = "Number of in-flight archive tasks")] pub in_flight_archive_tasks: Gauge, + + /// Number of failed archive tasks. + #[metric(describe = "Number of failed archive tasks")] + pub failed_archive_tasks: Counter, }