Skip to content

Commit

Permalink
Change aggregation job size metric
Browse files Browse the repository at this point in the history
  • Loading branch information
mendess committed Oct 4, 2023
1 parent e961693 commit ca82e78
Showing 1 changed file with 3 additions and 2 deletions.
5 changes: 3 additions & 2 deletions daphne/src/metrics.rs
Original file line number Diff line number Diff line change
Expand Up @@ -54,8 +54,9 @@ impl DaphneMetrics {
format!("{front}aggregation_job_batch_size"),
"Number of records in an incoming AggregationJobInitReq.",
&["host"],
exponential_buckets(5.0, 3.0, 6)
.expect("this shouldn't panic for these hardcoded values"), // <250, <500, ... <1500, +Inf
// <1, <2, <4, <8, ... <256, +Inf
exponential_buckets(1.0, 2.0, 8)
.expect("this shouldn't panic for these hardcoded values"),
registry
)
.map_err(|e| fatal_error!(err = ?e, "failed to register aggregation_job_batch_size"))?;
Expand Down

0 comments on commit ca82e78

Please sign in to comment.