在 Go 中，可以使用 Elasticsearch 官方提供的 Go 客户端库（github.com/elastic/go-elasticsearch）来检查 ES 集群的健康值。该客户端库提供了许多方法和结构体，以便于与 Elasticsearch 交互。
以下是一个示例代码，用于获取 ES 集群的健康值：
package main
import (
"context"
"fmt"
"log"
"github.com/elastic/go-elasticsearch/v7"
)
func main() {
// 创建一个 Elasticsearch 客户端
es, err := elasticsearch.NewDefaultClient()
if err != nil {
log.Fatalf("Error creating the client: %s", err)
}
// 发送集群健康请求
res, err := es.Cluster.Health(
es.Cluster.Health.WithContext(context.Background()),
es.Cluster.Health.WithIndex("my_index"),
es.Cluster.Health.WithWaitForStatus("yellow"), // 等待集群状态为黄色或更好
es.Cluster.Health.WithTimeout(30), // 设置超时时间为 30 秒
)
if err != nil {
log.Fatalf("Error getting cluster health: %s", err)
}
// 获取响应中的健康状态
health, _ := res.Status()
fmt.Printf("Cluster health is %q\n", health)
}
在上面的代码中，我们首先创建了一个默认配置的 Elasticsearch 客户端（elasticsearch.NewDefaultClient()）。然后，我们使用 es.Cluster.Health 方法发送一个集群健康请求，并通过各种选项来设置请求参数，例如：索引名称、期望的健康状态等。最后，我们通过 res.Status() 方法获取响应中的健康状态。
需要注意的是，在发送集群健康请求时，可以使用不同的选项来定制请求参数，以满足不同的需求。例如：
- WithIndex()：指定一个或多个索引名称。
- WithWaitForStatus()：指定期望的健康状态（green/yellow/red）。
- WithTimeout()：设置超时时间（单位为秒）。
- WithPretty()：指定是否将响应格式化为易于阅读的 JSON 格式。
总之，在 Go 中检查 ES 集群健康值非常简单，只需使用 Elasticsearch 官方提供的 Go 客户端库即可。
![5-01-15T13:58:44+08:00 [FATA][LIB][MonDB] server selection error: server selection timeout, current topology: { Type: Unknown, Servers: [{ Addr: 127.0.0.1:27017, Type: Unknown, Last error: connection() error occured during connection handshake: di...](https://linuxcpp.0voice.com/zb_users/upload/2023/05/202305162215397523846.png)
