kemko/nomad
1
0
Fork 0
mirror of https://github.com/kemko/nomad.git synced 2026-01-05 01:45:44 +03:00
Code Issues Packages Projects Releases Wiki Activity

Changed name of metric

Browse Source
This commit is contained in:
Preetha Appan
2019-06-17 15:51:31 -05:00
parent 9ab2207003
commit 2282fe1ea8
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
nomad/server.go
View File

@@ -1454,13 +1454,13 @@ func (s *Server) Stats() map[string]map[string]string {
return stats
}
// EmitRaftStats is used to export metrics about the blocked eval tracker while enabled
// EmitRaftStats is used to export metrics about raft indexes and state store snapshot index
func (s *Server) EmitRaftStats(period time.Duration, stopCh <-chan struct{}) {
for {
select {
case <-time.After(period):
commitIndex := s.raft.LastIndex()
metrics.SetGauge([]string{"raft", "commitIndex"}, float32(commitIndex))
lastIndex := s.raft.LastIndex()
metrics.SetGauge([]string{"raft", "lastIndex"}, float32(lastIndex))
appliedIndex := s.raft.AppliedIndex()
metrics.SetGauge([]string{"raft", "appliedIndex"}, float32(appliedIndex))
stateStoreSnapshotIndex, err := s.State().LatestIndex()