|
@@ -50,18 +50,18 @@ func (tw *metricsTxnWrite) End() {
|
|
|
defer tw.TxnWrite.End()
|
|
defer tw.TxnWrite.End()
|
|
|
if sum := tw.ranges + tw.puts + tw.deletes; sum > 1 {
|
|
if sum := tw.ranges + tw.puts + tw.deletes; sum > 1 {
|
|
|
txnCounter.Inc()
|
|
txnCounter.Inc()
|
|
|
- txnCounterDebug.Inc()
|
|
|
|
|
|
|
+ txnCounterDebug.Inc() // TODO: remove in 3.5 release
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
ranges := float64(tw.ranges)
|
|
ranges := float64(tw.ranges)
|
|
|
rangeCounter.Add(ranges)
|
|
rangeCounter.Add(ranges)
|
|
|
- rangeCounterDebug.Add(ranges)
|
|
|
|
|
|
|
+ rangeCounterDebug.Add(ranges) // TODO: remove in 3.5 release
|
|
|
|
|
|
|
|
puts := float64(tw.puts)
|
|
puts := float64(tw.puts)
|
|
|
putCounter.Add(puts)
|
|
putCounter.Add(puts)
|
|
|
- putCounterDebug.Add(puts)
|
|
|
|
|
|
|
+ putCounterDebug.Add(puts) // TODO: remove in 3.5 release
|
|
|
|
|
|
|
|
deletes := float64(tw.deletes)
|
|
deletes := float64(tw.deletes)
|
|
|
deleteCounter.Add(deletes)
|
|
deleteCounter.Add(deletes)
|
|
|
- deleteCounterDebug.Add(deletes)
|
|
|
|
|
|
|
+ deleteCounterDebug.Add(deletes) // TODO: remove in 3.5 release
|
|
|
}
|
|
}
|