Skip to content

Commit 603f6b2

Browse files
authored
chore: add metric for num in progress archive tasks (#127)
1 parent 9908c08 commit 603f6b2

File tree

3 files changed

+9
-1
lines changed

3 files changed

+9
-1
lines changed

.gitignore

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -24,3 +24,6 @@ Thumbs.db
2424
# Claude
2525
/.claude
2626
/ui/.claude
27+
28+
# e2e / load tests
29+
wallets.json

crates/audit/src/archiver.rs

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -50,6 +50,7 @@ where
5050
// TODO: the integration test breaks because Minio doesn't support etag
5151
let writer = self.writer.clone();
5252
let metrics = self.metrics.clone();
53+
self.metrics.in_flight_archive_tasks.increment(1.0);
5354
tokio::spawn(async move {
5455
let archive_start = Instant::now();
5556
if let Err(e) = writer.archive_event(event).await {
@@ -60,6 +61,7 @@ where
6061
.record(archive_start.elapsed().as_secs_f64());
6162
metrics.events_processed.increment(1);
6263
}
64+
metrics.in_flight_archive_tasks.decrement(1.0);
6365
});
6466

6567
let commit_start = Instant::now();

crates/audit/src/metrics.rs

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
use metrics::{Counter, Histogram};
1+
use metrics::{Counter, Gauge, Histogram};
22
use metrics_derive::Metrics;
33

44
#[derive(Metrics, Clone)]
@@ -33,4 +33,7 @@ pub struct Metrics {
3333

3434
#[metric(describe = "Total S3 writes skipped due to dedup")]
3535
pub s3_writes_skipped: Counter,
36+
37+
#[metric(describe = "Number of in-flight archive tasks")]
38+
pub in_flight_archive_tasks: Gauge,
3639
}

0 commit comments

Comments
 (0)