Mirroristas/etcd
2
0
Fork 0
mirror of https://github.com/etcd-io/etcd.git synced 2024-09-27 06:25:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #11394 from jingyih/automated-cherry-pick-of-#11374-upstream-release-3.3

Browse Source 
Automated cherry pick of #11374 on release 3.3
This commit is contained in:
Wenjia 2019-11-26 15:02:17 -08:00 committed by GitHub
commit 9cd3eefd01
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 15 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
mvcc/metrics.go
View File

@ -238,6 +238,14 @@ var (
// overridden by mvcc initialization // overridden by mvcc initialization
reportCompactRevMu sync.RWMutex reportCompactRevMu sync.RWMutex
reportCompactRev = func() float64 { return 0 } reportCompactRev = func() float64 { return 0 }
totalPutSizeGauge = prometheus.NewGauge(
prometheus.GaugeOpts{
Namespace: "etcd_debugging",
Subsystem: "mvcc",
Name: "total_put_size_in_bytes",
Help: "The total size of put kv pairs seen by this member.",
})
) )
func init() { func init() {
@ -262,6 +270,7 @@ func init() {
prometheus.MustRegister(hashRevDurations) prometheus.MustRegister(hashRevDurations)
prometheus.MustRegister(currentRev) prometheus.MustRegister(currentRev)
prometheus.MustRegister(compactRev) prometheus.MustRegister(compactRev)
prometheus.MustRegister(totalPutSizeGauge)
} }
// ReportEventReceived reports that an event is received. // ReportEventReceived reports that an event is received.

8
mvcc/metrics_txn.go
View File

@ -23,14 +23,15 @@ type metricsTxnWrite struct {
ranges uint ranges uint
puts uint puts uint
deletes uint deletes uint
putSize int64
} }
func newMetricsTxnRead(tr TxnRead) TxnRead { func newMetricsTxnRead(tr TxnRead) TxnRead {
return &metricsTxnWrite{&txnReadWrite{tr}, 0, 0, 0} return &metricsTxnWrite{&txnReadWrite{tr}, 0, 0, 0, 0}
} }
func newMetricsTxnWrite(tw TxnWrite) TxnWrite { func newMetricsTxnWrite(tw TxnWrite) TxnWrite {
return &metricsTxnWrite{tw, 0, 0, 0} return &metricsTxnWrite{tw, 0, 0, 0, 0}
} }
func (tw *metricsTxnWrite) Range(key, end []byte, ro RangeOptions) (*RangeResult, error) { func (tw *metricsTxnWrite) Range(key, end []byte, ro RangeOptions) (*RangeResult, error) {
@ -45,6 +46,8 @@ func (tw *metricsTxnWrite) DeleteRange(key, end []byte) (n, rev int64) {
func (tw *metricsTxnWrite) Put(key, value []byte, lease lease.LeaseID) (rev int64) { func (tw *metricsTxnWrite) Put(key, value []byte, lease lease.LeaseID) (rev int64) {
tw.puts++ tw.puts++
size := int64(len(key) + len(value))
tw.putSize += size
return tw.TxnWrite.Put(key, value, lease) return tw.TxnWrite.Put(key, value, lease)
} }
@ -55,5 +58,6 @@ func (tw *metricsTxnWrite) End() {
} }
rangeCounter.Add(float64(tw.ranges)) rangeCounter.Add(float64(tw.ranges))
putCounter.Add(float64(tw.puts)) putCounter.Add(float64(tw.puts))
totalPutSizeGauge.Add(float64(tw.putSize))
deleteCounter.Add(float64(tw.deletes)) deleteCounter.Add(float64(tw.deletes))
} }