使用Informer监听Pod事件：通过client-go创建Kubernetes客户端，初始化SharedInformerFactory并获取Pod Informer，添加Add/Update/Delete事件处理函数，启动Informer并等待事件。示例代码展示了在默认命名空间中监听Pod变化，使用InClusterConfig获取配置，每30秒同步一次缓存，并打印增删改日志。
在Go语言中监听Kubernetes Pod事件，通常通过官方提供的client-go库实现。核心思路是使用Informer或直接调用Watch接口来监听Pod资源的变化，比如创建、更新和删除。
1. 使用 Informer 监听 Pod 事件
Informer是client-go中最常用的机制，能高效地监听资源变更并执行回调函数。
步骤如下：
- 创建 Kubernetes 客户端
- 初始化 SharedInformerFactory 并获取 Pod Informer
- 添加事件处理函数（Add/Update/Delete）
- 启动 Informer 并等待事件
package main
import (
"context"
"log"
"time"
v1 "k8s.io/api/core/v1"
"k8s.io/client-go/informers"
"k8s.io/client-go/kubernetes"
"k8s.io/client-go/rest"
"k8s.io/client-go/tools/cache"
)
func main() {
// 使用 In-cluster 配置（运行在 Pod 中）
config, err := rest.InClusterConfig()
// 若本地测试，可使用 kubeconfig
// config, err := clientcmd.BuildConfigFromFlags("", "/path/to/kubeconfig")
if err != nil {
log.Fatal(err)
}
clientset, err := kubernetes.NewForConfig(config)
if err != nil {
log.Fatal(err)
}
// 创建 SharedInformerFactory，监听默认命名空间，每30秒同步一次
factory := informers.NewSharedInformerFactoryWithOptions(
clientset,
30*time.Second,
informers.WithNamespace(v1.NamespaceDefault), // 可改为 "" 监听所有命名空间
)
podInformer := factory.Core().V1().Pods().Informer()
stopper := make(chan struct{})
defer close(stopper)
// 添加事件处理
podInformer.AddEventHandler(cache.ResourceEventHandlerFuncs{
AddFunc: func(obj interface{}) {
pod := obj.(*v1.Pod)
log.Printf("Pod 添加: %s/%s", pod.Namespace, pod.Name)
},
UpdateFunc: func(old, new interface{}) {
oldPod := old.(*v1.Pod)
newPod := new.(*v1.Pod)
if oldPod.ResourceVersion == newPod.ResourceVersion {
return // 无实际变更
}
log.Printf("Pod 更新: %s/%s", newPod.Namespace, newPod.Name)
},
DeleteFunc: func(obj interface{}) {
pod := obj.(*v1.Pod)
log.Printf("Pod 删除: %s/%s", pod.Namespace, pod.Name)
},
})
// 启动 Informer
factory.Start(stopper)
factory.WaitForCacheSync(stopper)
log.Println("开始监听 Pod 事件...")
<-stopper
}
2. 使用 Watch API 直接监听
若只需要临时监听某次事件，可以直接使用Watch接口。
立即学习“go语言免费学习笔记（深入）”；
示例代码片段：watch, err := clientset.CoreV1().Pods("default").Watch(context.TODO(), metav1.ListOptions{})
if err != nil {
log.Fatal(err)
}
defer watch.Stop()
for event := range watch.ResultChan() {
pod := event.Object.(*v1.Pod)
log.Printf("事件类型: %s, Pod: %s", event.Type, pod.Name)
}
这种方式更轻量，适合一次性或短时任务，但不提供本地缓存和重试机制。
3. 注意事项与最佳实践
- 命名空间选择：根据需要监听特定命名空间或全部（设置 namespace 为 ""）
- 权限控制：确保 ServiceAccount 有足够的 RBAC 权限（如 get, list, watch pods）
- 事件去重：Update 事件可能频繁触发，建议比较 ResourceVersion 避免重复处理
- 错误处理与重连：Informer 内部已处理网络中断和重连，无需手动干预
- 资源释放：程序退出时关闭 stopper 通道，避免 goroutine 泄漏
基本上就这些。使用 Informer 是最推荐的方式，稳定且功能完整。结合日志、告警或自定义控制器逻辑，可以构建出强大的运维工具。
