最可靠低延迟监控Kubernetes Pod状态的方式是使用client-go的Watch或Informer机制；Watch需先List获取ResourceVersion再启动，Informer则自动缓存与重连，避免轮询浪费资源和错过瞬时状态。
用 Golang 监控 Kubernetes Pod 状态，最可靠、低延迟的方式不是轮询 List()，而是走 client-go 的 Watch 或 Informer 机制；轮询不仅浪费 API Server 资源，还会错过中间状态（比如 Pending → Running → CrashLoopBackOff 的瞬时跳变）。
用 Watch 实现事件驱动监听
Watch 是 Kubernetes API 原生支持的流式监听能力，client-go 封装为 Watch() 方法，返回 watch.Interface，持续接收 watch.Event（Added、Modified、Deleted）。关键点在于：必须带 ResourceVersion 启动，否则会收到全量历史事件甚至报错 410 Gone。
- 先调一次
List()获取初始状态和最新ResourceVersion - 再用该
ResourceVersion发起Watch()，避免重复事件或连接中断后丢事件 - 监听时务必加
LabelSelector和Namespace，否则默认监听全集群 Pod —— 权限不够会报错，权限够了也会拖慢性能 - 注意处理
watch.Error类型事件：可能是连接断开、权限变更或 resourceVersion 过期，需自动重试并重新List()
用 Informer 省掉手动缓存与重连
如果你需要频繁查 Pod 当前状态（比如做健康聚合、调度决策），直接反复 Get() 效率低且易触发限流；Informer 自动维护本地内存缓存（cache.Indexer），还内置重连、reflector、DeltaFIFO 等机制，适合生产环境长期运行。
- 初始化时传入
SharedInformerFactory，调用Pods(namespace).Informer()即可获得 - 缓存中的 Pod 可用
informer.GetIndexer().List()或ByIndex("namespace", ns)快速获取，不走网络 - 注册回调用
AddEventHandler()，其中OnAdd/OnUpdate参数是*v1.Pod指针，别直接存引用 —— Informer 内部会复用对象 - 启动前记得调
informer.Run(stopCh)，且stopCh必须在程序退出时关闭，否则 goroutine 泄漏
绕过 client-go：用 http.Client 直连 watch endpoint
极简场景（如单文件诊断脚本、嵌入式工具）不想引入 client-go 时，可直接调用 kube-apiserver 的 watch 接口。但要注意响应是流式 JSON Lines（每行一个完整 JSON 对象），不能用 json.Unmarshal() 一次性解整个 body。
立即学习“go语言免费学习笔记（深入）”；
- 请求 URL 示例：
https://<host>/api/v1/namespaces/default/pods?watch=true&resourceVersion=12345</host> - 逐行读取响应体，用
json.Decoder.Decode()解析每一行到watch.Event结构体 - 自己解析
event.Type和event.Object字段（后者需二次反序列化为*v1.Pod） - 必须处理 HTTP 连接中断、超时、重定向；建议加指数退避重连，且每次重连都重新
List()获取新resourceVersion
package main
<p>import (
"bufio"
"context"
"encoding/json"
"fmt"
"io"
"net/http"
"time"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
"k8s.io/apimachinery/pkg/apis/meta/v1/unstructured"
"k8s.io/apimachinery/pkg/runtime/serializer/json"
)</p><p>func watchRawPods() {
client := &http.Client{Timeout: 30 * time.Second}
req, _ := http.NewRequest("GET", "<a href="https://www.php.cn/link/a87af548651faf99448576a18ececddd">https://www.php.cn/link/a87af548651faf99448576a18ececddd</a>", nil)
req.Header.Set("Authorization", "Bearer YOUR_TOKEN")
req.Header.Set("Accept", "application/json")</p><pre class='brush:php;toolbar:false;'>resp, err := client.Do(req)
if err != nil {
panic(err)
}
defer resp.Body.Close()
dec := json.NewSerializer(json.DefaultMetaFactory, nil, nil, false)
scanner := bufio.NewScanner(resp.Body)
for scanner.Scan() {
line := scanner.Bytes()
var event unstructured.Unstructured
if _, _, err := dec.Decode(line, nil, &event); err == nil {
fmt.Printf("Event type: %s, Name: %s\n",
event.Object["type"],
event.Object["object"].(map[string]interface{})["metadata"].(map[string]interface{})["name"])
}
}}
真正难的不是写通 Watch，而是处理好边界：resourceVersion 过期怎么续、事件乱序怎么幂等、多个监听器如何共享缓存、Pod 状态字段（如 Phase、ContainerStatuses、Conditions）哪些可信哪些要交叉验证 —— 这些细节不踩一遍坑，监控系统上线后大概率变成“看起来在跑，其实漏报”。
