Golang如何处理Kubernetes Pod事件监听_石家庄创泽智能科技有限公司

新闻中心 NEWS CENTER

您当前位置：首页 > 新闻中心 > 网络学院

Golang如何处理Kubernetes Pod事件监听

2025-11-11

浏览次数：次

返回列表

使用Informer监听Pod事件：通过client-go创建Kubernetes客户端，初始化SharedInformerFactory并获取Pod Informer，添加Add/Update/Delete事件处理函数，启动Informer并等待事件。示例代码展示了在默认命名空间中监听Pod变化，使用InClusterConfig获取配置，每30秒同步一次缓存，并打印增删改日志。

golang如何处理kubernetes pod事件监听

在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接口。

千鹿Pr助手

智能Pr插件，融入众多AI功能和海量素材

128 查看详情千鹿Pr助手

示例代码片段：

watch, err := clientset.CoreV1().Pods("default").Watch(context.TODO(), met*1.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)
}

这种方式更轻量，适合一次性或短时任务，但不提供本地缓存和重试机制。