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

mvcc: add "etcd_mvcc_hash_(rev)_duration_seconds"

Browse Source 
etcd_mvcc_hash_duration_seconds
etcd_mvcc_hash_rev_duration_seconds

Signed-off-by: Gyuho Lee <gyuhox@gmail.com>
This commit is contained in:
Gyuho Lee 2018-05-23 12:34:09 -07:00
parent 966ee9323c
commit bc59f7b42f
2 changed files with 36 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
mvcc/kvstore.go
View File

@ -163,12 +163,18 @@ func (s *store) compactBarrier(ctx context.Context, ch chan struct{}) {
} }
func (s *store) Hash() (hash uint32, revision int64, err error) { func (s *store) Hash() (hash uint32, revision int64, err error) {
start := time.Now()
s.b.ForceCommit() s.b.ForceCommit()
h, err := s.b.Hash(DefaultIgnores) h, err := s.b.Hash(DefaultIgnores)
hashDurations.Observe(time.Since(start).Seconds())
return h, s.currentRev, err return h, s.currentRev, err
} }
func (s *store) HashByRev(rev int64) (hash uint32, currentRev int64, compactRev int64, err error) { func (s *store) HashByRev(rev int64) (hash uint32, currentRev int64, compactRev int64, err error) {
start := time.Now()
s.mu.RLock() s.mu.RLock()
s.revMu.RLock() s.revMu.RLock()
compactRev, currentRev = s.compactMainRev, s.currentRev compactRev, currentRev = s.compactMainRev, s.currentRev
@ -213,7 +219,10 @@ func (s *store) HashByRev(rev int64) (hash uint32, currentRev int64, compactRev
h.Write(v) h.Write(v)
return nil return nil
}) })
return h.Sum32(), currentRev, compactRev, err hash = h.Sum32()
hashRevDurations.Observe(time.Since(start).Seconds())
return hash, currentRev, compactRev, err
} }
func (s *store) Compact(rev int64) (<-chan struct{}, error) { func (s *store) Compact(rev int64) (<-chan struct{}, error) {

26
mvcc/metrics.go
View File

@ -170,6 +170,30 @@ var (
// overridden by mvcc initialization // overridden by mvcc initialization
reportDbTotalSizeInUseInBytesMu sync.RWMutex reportDbTotalSizeInUseInBytesMu sync.RWMutex
reportDbTotalSizeInUseInBytes func() float64 = func() float64 { return 0 } reportDbTotalSizeInUseInBytes func() float64 = func() float64 { return 0 }
hashDurations = prometheus.NewHistogram(prometheus.HistogramOpts{
Namespace: "etcd",
Subsystem: "mvcc",
Name: "hash_duration_seconds",
Help: "The latency distribution of storage hash operation.",
// 100 MB usually takes 100 ms, so start with 10 MB of 10 ms
// lowest bucket start of upper bound 0.01 sec (10 ms) with factor 2
// highest bucket start of 0.01 sec * 2^14 == 163.84 sec
Buckets: prometheus.ExponentialBuckets(.01, 2, 15),
})
hashRevDurations = prometheus.NewHistogram(prometheus.HistogramOpts{
Namespace: "etcd",
Subsystem: "mvcc",
Name: "hash_rev_duration_seconds",
Help: "The latency distribution of storage hash by revision operation.",
// 100 MB usually takes 100 ms, so start with 10 MB of 10 ms
// lowest bucket start of upper bound 0.01 sec (10 ms) with factor 2
// highest bucket start of 0.01 sec * 2^14 == 163.84 sec
Buckets: prometheus.ExponentialBuckets(.01, 2, 15),
})
) )
func init() { func init() {
@ -189,6 +213,8 @@ func init() {
prometheus.MustRegister(dbCompactionKeysCounter) prometheus.MustRegister(dbCompactionKeysCounter)
prometheus.MustRegister(dbTotalSize) prometheus.MustRegister(dbTotalSize)
prometheus.MustRegister(dbTotalSizeInUse) prometheus.MustRegister(dbTotalSizeInUse)
prometheus.MustRegister(hashDurations)
prometheus.MustRegister(hashRevDurations)
} }
// ReportEventReceived reports that an event is received. // ReportEventReceived reports that an event is received.