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: rename to "heartbeat_send_failures_total"

Browse Source 
Signed-off-by: Gyuho Lee <gyuhox@gmail.com>
This commit is contained in:
Gyuho Lee 2018-05-23 13:09:31 -07:00
parent bc59f7b42f
commit a1aade8c1b
2 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
etcdserver/metrics.go
View File

@ -42,11 +42,11 @@ var (
Name: "leader_changes_seen_total", Name: "leader_changes_seen_total",
Help: "The number of leader changes seen.", Help: "The number of leader changes seen.",
}) })
heartbeatFailures = prometheus.NewCounter(prometheus.CounterOpts{ heartbeatSendFailures = prometheus.NewCounter(prometheus.CounterOpts{
Namespace: "etcd", Namespace: "etcd",
Subsystem: "server", Subsystem: "server",
Name: "heartbeat_failures_total", Name: "heartbeat_send_failures_total",
Help: "The total number of heartbeat send failures (likely overloaded from slow disk).", Help: "The total number of leader heartbeat send failures (likely overloaded from slow disk).",
}) })
slowApplies = prometheus.NewCounter(prometheus.CounterOpts{ slowApplies = prometheus.NewCounter(prometheus.CounterOpts{
Namespace: "etcd", Namespace: "etcd",
@ -97,7 +97,7 @@ func init() {
prometheus.MustRegister(hasLeader) prometheus.MustRegister(hasLeader)
prometheus.MustRegister(isLeader) prometheus.MustRegister(isLeader)
prometheus.MustRegister(leaderChanges) prometheus.MustRegister(leaderChanges)
prometheus.MustRegister(heartbeatFailures) prometheus.MustRegister(heartbeatSendFailures)
prometheus.MustRegister(slowApplies) prometheus.MustRegister(slowApplies)
prometheus.MustRegister(proposalsCommitted) prometheus.MustRegister(proposalsCommitted)
prometheus.MustRegister(proposalsApplied) prometheus.MustRegister(proposalsApplied)

4
etcdserver/raft.go
View File

@ -368,7 +368,7 @@ func (r *raftNode) processMessages(ms []raftpb.Message) []raftpb.Message {
// TODO: limit request rate. // TODO: limit request rate.
if r.lg != nil { if r.lg != nil {
r.lg.Warn( r.lg.Warn(
"failed to send out heartbeat; took too long, server is overloaded likely from slow disk", "leader failed to send out heartbeat on time; took too long, leader is overloaded likely from slow disk",
zap.Duration("heartbeat-interval", r.heartbeat), zap.Duration("heartbeat-interval", r.heartbeat),
zap.Duration("expected-duration", 2*r.heartbeat), zap.Duration("expected-duration", 2*r.heartbeat),
zap.Duration("exceeded-duration", exceed), zap.Duration("exceeded-duration", exceed),
@ -377,7 +377,7 @@ func (r *raftNode) processMessages(ms []raftpb.Message) []raftpb.Message {
plog.Warningf("failed to send out heartbeat on time (exceeded the %v timeout for %v)", r.heartbeat, exceed) plog.Warningf("failed to send out heartbeat on time (exceeded the %v timeout for %v)", r.heartbeat, exceed)
plog.Warningf("server is likely overloaded") plog.Warningf("server is likely overloaded")
} }
heartbeatFailures.Inc() heartbeatSendFailures.Inc()
} }
} }
} }