Skip to content

Commit fd56f6f

Browse files
committed
asim: include WriteBytesPerSecond in StoreMetrics
Previously, we added WriteBytesPerSecond to Capacity and included it in StoreMetrics, but it wasn't populated correctly. This commit fixes that by properly setting the field when creating StoreMetrics. Epic: none Release note: none
1 parent ef2fc85 commit fd56f6f

File tree

1 file changed

+17
-16
lines changed

1 file changed

+17
-16
lines changed

pkg/kv/kvserver/asim/metrics/tracker.go

Lines changed: 17 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -141,22 +141,23 @@ func (mt *Tracker) Tick(ctx context.Context, tick time.Time, s state.State) {
141141
desc := store.Descriptor()
142142

143143
sm := StoreMetrics{
144-
Tick: tick,
145-
StoreID: int64(storeID),
146-
QPS: int64(desc.Capacity.QueriesPerSecond),
147-
CPU: int64(desc.Capacity.CPUPerSecond),
148-
WriteKeys: u.WriteKeys,
149-
WriteBytes: u.WriteBytes,
150-
ReadKeys: u.ReadKeys,
151-
ReadBytes: u.ReadBytes,
152-
Replicas: int64(desc.Capacity.RangeCount),
153-
Leases: int64(desc.Capacity.LeaseCount),
154-
LeaseTransfers: u.LeaseTransfers,
155-
Rebalances: u.Rebalances,
156-
RebalanceSentBytes: u.RebalanceSentBytes,
157-
RebalanceRcvdBytes: u.RebalanceRcvdBytes,
158-
RangeSplits: u.RangeSplits,
159-
DiskFractionUsed: desc.Capacity.FractionUsed(),
144+
Tick: tick,
145+
StoreID: int64(storeID),
146+
QPS: int64(desc.Capacity.QueriesPerSecond),
147+
CPU: int64(desc.Capacity.CPUPerSecond),
148+
WriteKeys: u.WriteKeys,
149+
WriteBytes: u.WriteBytes,
150+
WriteBytesPerSecond: int64(desc.Capacity.WriteBytesPerSecond),
151+
ReadKeys: u.ReadKeys,
152+
ReadBytes: u.ReadBytes,
153+
Replicas: int64(desc.Capacity.RangeCount),
154+
Leases: int64(desc.Capacity.LeaseCount),
155+
LeaseTransfers: u.LeaseTransfers,
156+
Rebalances: u.Rebalances,
157+
RebalanceSentBytes: u.RebalanceSentBytes,
158+
RebalanceRcvdBytes: u.RebalanceRcvdBytes,
159+
RangeSplits: u.RangeSplits,
160+
DiskFractionUsed: desc.Capacity.FractionUsed(),
160161
}
161162
sms = append(sms, sm)
162163
}

0 commit comments

Comments
 (0)