最可靠低延迟监控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.U 一次性解整个 body。
- 请求 URL 示例：
https:///api/v1/namespaces/default/pods?watch=true&resourceVersion=12345 - 逐行读取响应体，用
json.Decoder.Decode()解析每一行到watch.Event结构体 - 自己解析
event.Type和event.Object字段（后者需二次反序列化为*v1.Pod） - 必须处理 HTTP 连接中断、超时、重定向；建议加指数退避重连，且每次重连都重新
List()获取新resourceVersion
package mainimport ( "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" )
func watchRawPods() { client := &http.Client{Timeout: 30 * time.Second} req, _ := http.NewRequest("GET", "https://www./link/a87af548651faf99448576a18ececddd", nil) req.Header.Set("Authorization", "Bearer YOUR_TOKEN") req.Header.Set("Accept", "application/json")
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）哪些可信哪些要交叉验证 —— 这些细节不踩一遍坑，监控系统上线后大概率变成“看起来在跑，其实漏报”。
