Skip to content

Commit

Permalink
kvserver: update the send queue size metrics
Browse files Browse the repository at this point in the history
This is a tiny bug fix, in that all the plumbing work was already done,
and just the update calls were forgotten.

Epic: CRDB-37515

Release note: None
  • Loading branch information
sumeerbhola committed Oct 11, 2024
1 parent 76266cf commit 0b0803b
Showing 1 changed file with 2 additions and 0 deletions.
2 changes: 2 additions & 0 deletions pkg/kv/kvserver/store.go
Original file line number Diff line number Diff line change
Expand Up @@ -3484,6 +3484,8 @@ func (s *Store) updateReplicationGauges(ctx context.Context) error {
nanos := timeutil.Since(minMaxClosedTS.GoTime()).Nanoseconds()
s.metrics.ClosedTimestampMaxBehindNanos.Update(nanos)
}
s.cfg.KVFlowRangeControllerMetrics.SendQueue.SizeCount.Update(kvflowSendQueueSizeCount)
s.cfg.KVFlowRangeControllerMetrics.SendQueue.SizeBytes.Update(kvflowSendQueueSizeBytes)

if err := s.metrics.RecentReplicaCPUNanosPerSecond.Rotate(); err != nil {
return err
Expand Down

0 comments on commit 0b0803b

Please sign in to comment.