agent: add server raft.{last,applied}_index gauges (#6694)
These metrics are useful for : * Tracking the rate of update to the db * Allow to have a rough idea of when an index originated
This commit is contained in:
parent
1c88dc15ef
commit
a27ccc7248
|
@ -543,7 +543,7 @@ func NewServerLogger(config *Config, logger hclog.InterceptLogger, tokens *token
|
|||
}
|
||||
|
||||
// Start the metrics handlers.
|
||||
go s.sessionStats()
|
||||
go s.updateMetrics()
|
||||
|
||||
return s, nil
|
||||
}
|
||||
|
|
|
@ -130,14 +130,16 @@ func (s *Server) clearAllSessionTimers() {
|
|||
s.sessionTimers.StopAll()
|
||||
}
|
||||
|
||||
// sessionStats is a long running routine used to capture
|
||||
// the number of active sessions being tracked
|
||||
func (s *Server) sessionStats() {
|
||||
// updateMetrics is a long running routine used to uddate a
|
||||
// number of server periodic metrics
|
||||
func (s *Server) updateMetrics() {
|
||||
for {
|
||||
select {
|
||||
case <-time.After(5 * time.Second):
|
||||
case <-time.After(time.Second):
|
||||
metrics.SetGauge([]string{"session_ttl", "active"}, float32(s.sessionTimers.Len()))
|
||||
|
||||
metrics.SetGauge([]string{"raft", "applied_index"}, float32(s.raft.AppliedIndex()))
|
||||
metrics.SetGauge([]string{"raft", "last_index"}, float32(s.raft.LastIndex()))
|
||||
case <-s.shutdownCh:
|
||||
return
|
||||
}
|
||||
|
|
Loading…
Reference in New Issue