diff --git a/monkit.lock b/monkit.lock index d1f73c00e..6bfad7daf 100644 --- a/monkit.lock +++ b/monkit.lock @@ -62,6 +62,8 @@ storj.io/storj/satellite/gracefulexit."graceful_exit_successful_pieces_transfer_ storj.io/storj/satellite/gracefulexit."graceful_exit_transfer_piece_fail" Meter storj.io/storj/satellite/gracefulexit."graceful_exit_transfer_piece_success" Meter storj.io/storj/satellite/metainfo."metainfo_rate_limit_exceeded" Event +storj.io/storj/satellite/metainfo/piecedeletion."delete_batch_size" IntVal +storj.io/storj/satellite/metainfo/piecedeletion."deletion_pieces_unhandled_count" IntVal storj.io/storj/satellite/orders."download_failed_not_enough_pieces_uplink" Meter storj.io/storj/satellite/repair/checker."checker_injured_segment_health" FloatVal storj.io/storj/satellite/repair/checker."checker_segment_age" IntVal diff --git a/satellite/metainfo/piecedeletion/dialer.go b/satellite/metainfo/piecedeletion/dialer.go index 18cd02ae2..c3d922028 100644 --- a/satellite/metainfo/piecedeletion/dialer.go +++ b/satellite/metainfo/piecedeletion/dialer.go @@ -83,9 +83,9 @@ func (dialer *Dialer) Handle(ctx context.Context, node storj.NodeURL, queue Queu for len(jobs) > 0 { batch, promises, rest := batchJobs(jobs, dialer.piecesPerRequest) // Aggregation metrics - mon.IntVal("delete batch size").Observe(int64(len(batch))) + mon.IntVal("delete_batch_size").Observe(int64(len(batch))) //mon:locked // Tracing metrics - s.Annotate("delete batch size", strconv.Itoa(len(batch))) + s.Annotate("delete_batch_size", strconv.Itoa(len(batch))) jobs = rest @@ -111,7 +111,7 @@ func (dialer *Dialer) Handle(ctx context.Context, node storj.NodeURL, queue Queu } break } else { - mon.IntVal("deletion pieces unhandled count").Observe(resp.UnhandledCount) + mon.IntVal("deletion_pieces_unhandled_count").Observe(resp.UnhandledCount) //mon:locked } jobs = append(jobs, queue.PopAllWithoutClose()...)