JakeHillion/storj
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

satellite/metainfo/piecedeletion Remove spaces from metrics.

Browse Source 
Change-Id: Iaf1d8a96a43087f2fcc579347f581e8a78a0fb58
This commit is contained in:
Rafael Gomes 2020-12-30 14:03:31 -03:00
parent 7246368ca1
commit 8b2e4bfa7e
2 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
monkit.lock
View File

@ -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

6
satellite/metainfo/piecedeletion/dialer.go
View File

@ -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()...)