1 files changed, 62 insertions, 0 deletions
diff --git a/src/go/collectors/go.d.plugin/modules/consul/collect_autopilot.go b/src/go/collectors/go.d.plugin/modules/consul/collect_autopilot.go
new file mode 100644
index 000000000..e73ce9b25
--- /dev/null
+++ b/src/go/collectors/go.d.plugin/modules/consul/collect_autopilot.go
@@ -0,0 +1,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
+}