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

etcdserver: add "etcd_server_read_indexes_failed_total"

Browse Source 
Signed-off-by: Gyuho Lee <leegyuho@amazon.com>
This commit is contained in:
Gyuho Lee 2018-10-09 18:21:06 -07:00
parent b6d11019e0
commit 6e15f11fd9
2 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
etcdserver/metrics.go
View File

@ -90,6 +90,12 @@ var (
Name: "slow_read_indexes_total", Name: "slow_read_indexes_total",
Help: "The total number of pending read indexes not in sync with leader's or timed out read index requests.", Help: "The total number of pending read indexes not in sync with leader's or timed out read index requests.",
}) })
readIndexFailed = prometheus.NewCounter(prometheus.CounterOpts{
Namespace: "etcd",
Subsystem: "server",
Name: "read_indexes_failed_total",
Help: "The total number of failed read indexes seen.",
})
quotaBackendBytes = prometheus.NewGauge(prometheus.GaugeOpts{ quotaBackendBytes = prometheus.NewGauge(prometheus.GaugeOpts{
Namespace: "etcd", Namespace: "etcd",
Subsystem: "server", Subsystem: "server",
@ -131,6 +137,7 @@ func init() {
prometheus.MustRegister(proposalsFailed) prometheus.MustRegister(proposalsFailed)
prometheus.MustRegister(leaseExpired) prometheus.MustRegister(leaseExpired)
prometheus.MustRegister(slowReadIndex) prometheus.MustRegister(slowReadIndex)
prometheus.MustRegister(readIndexFailed)
prometheus.MustRegister(quotaBackendBytes) prometheus.MustRegister(quotaBackendBytes)
prometheus.MustRegister(currentVersion) prometheus.MustRegister(currentVersion)
prometheus.MustRegister(currentGoVersion) prometheus.MustRegister(currentGoVersion)

1
etcdserver/v3_server.go
View File

@ -621,6 +621,7 @@ func (s *EtcdServer) linearizableReadLoop() {
return return
} }
plog.Errorf("failed to get read index from raft: %v", err) plog.Errorf("failed to get read index from raft: %v", err)
readIndexFailed.Inc()
nr.notify(err) nr.notify(err)
continue continue
} }