使用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接口。

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 是最推荐的方式，稳定且功能完整。结合日志、告警或自定义控制器逻辑，可以构建出强大的运维工具。