Skip to content

Commit

Permalink
computed fields for bloomgw stats logging
Browse files Browse the repository at this point in the history
Signed-off-by: Owen Diehl <ow.diehl@gmail.com>
  • Loading branch information
owen-d committed Mar 26, 2024
1 parent 6b3bbb3 commit ec236cf
Showing 1 changed file with 16 additions and 0 deletions.
16 changes: 16 additions & 0 deletions pkg/bloomgateway/stats.go
Original file line number Diff line number Diff line change
Expand Up @@ -35,22 +35,38 @@ func FromContext(ctx context.Context) *Stats {
return o.(*Stats)
}

// aggregates the total duration
func (s *Stats) Duration() (dur time.Duration) {
dur += s.QueueTime.Load()
dur += s.MetasFetchTime.Load()
dur += s.BlocksFetchTime.Load()
dur += s.ProcessingTime.Load()
dur += s.PostProcessingTime.Load()
return
}

func (s *Stats) KVArgs() []any {
if s == nil {
return []any{}
}
chunksRemaining := s.ChunksRequested - s.ChunksFiltered
filterRatio := float64(s.ChunksFiltered) / float64(max(s.ChunksRequested, 1))

return []any{
"status", s.Status,
"tasks", s.NumTasks,
"series_requested", s.SeriesRequested,
"series_filtered", s.SeriesFiltered,
"chunks_requested", s.ChunksRequested,
"chunks_filtered", s.ChunksFiltered,
"chunks_remaining", chunksRemaining,
"filter_ratio", filterRatio,
"queue_time", s.QueueTime.Load(),
"metas_fetch_time", s.MetasFetchTime.Load(),
"blocks_fetch_time", s.BlocksFetchTime.Load(),
"processing_time", s.ProcessingTime.Load(),
"post_processing_time", s.PostProcessingTime.Load(),
"duration", s.Duration(),
}
}

Expand Down

0 comments on commit ec236cf

Please sign in to comment.