blob: e73ce9b253b1c5f6d45fcd3e1e9f2e506d6c3db6 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
|
// SPDX-License-Identifier: GPL-3.0-or-later
package consul
import (
"net/http"
"time"
)
const (
// https://developer.hashicorp.com/consul/api-docs/operator/autopilot#read-health
urlPathOperationAutopilotHealth = "/v1/operator/autopilot/health"
)
type autopilotHealth struct {
Servers []struct {
ID string
SerfStatus string
Leader bool
LastContact string
Healthy bool
Voter bool
StableSince time.Time
}
}
func (c *Consul) collectAutopilotHealth(mx map[string]int64) error {
var health autopilotHealth
// The HTTP status code will indicate the health of the cluster: 200 is healthy, 429 is unhealthy.
// https://github.com/hashicorp/consul/blob/c7ef04c5979dbc311ff3c67b7bf3028a93e8b0f1/agent/operator_endpoint.go#L325
if err := c.doOKDecode(urlPathOperationAutopilotHealth, &health, http.StatusTooManyRequests); err != nil {
return err
}
for _, srv := range health.Servers {
if srv.ID == c.cfg.Config.NodeID {
// SerfStatus: alive, left, failed or none:
// https://github.com/hashicorp/consul/blob/c7ef04c5979dbc311ff3c67b7bf3028a93e8b0f1/agent/consul/operator_autopilot_endpoint.go#L124-L133
mx["autopilot_server_sefStatus_alive"] = boolToInt(srv.SerfStatus == "alive")
mx["autopilot_server_sefStatus_left"] = boolToInt(srv.SerfStatus == "left")
mx["autopilot_server_sefStatus_failed"] = boolToInt(srv.SerfStatus == "failed")
mx["autopilot_server_sefStatus_none"] = boolToInt(srv.SerfStatus == "none")
// https://github.com/hashicorp/raft-autopilot/blob/d936f51c374c3b7902d5e4fdafe9f7d8d199ea53/types.go#L110
mx["autopilot_server_healthy_yes"] = boolToInt(srv.Healthy)
mx["autopilot_server_healthy_no"] = boolToInt(!srv.Healthy)
mx["autopilot_server_voter_yes"] = boolToInt(srv.Voter)
mx["autopilot_server_voter_no"] = boolToInt(!srv.Voter)
mx["autopilot_server_stable_time"] = int64(time.Since(srv.StableSince).Seconds())
mx["autopilot_server_stable_time"] = int64(time.Since(srv.StableSince).Seconds())
if !srv.Leader {
if v, err := time.ParseDuration(srv.LastContact); err == nil {
mx["autopilot_server_lastContact_leader"] = v.Milliseconds()
}
}
break
}
}
return nil
}
|
