如何使用client-go API获取Kubernetes中Pod的事件消息？

可以实现。kubectl的describe pod命令本身就是调用Kubernetes API实现事件查询，你完全可以通过client-go复刻该逻辑，甚至自定义事件的筛选、格式化规则。

• 1. 初始化client-go客户端
     首先配置集群访问凭证：
  • 如果你是在集群外部运行程序，使用k8s.io/client-go/tools/clientcmd加载本地kubeconfig文件生成访问配置
  • 如果你是在集群内部的Pod中运行程序，直接调用k8s.io/client-go/rest.InClusterConfig()获取集群内访问配置
    用生成的配置初始化CoreV1客户端，参考代码：

  import (
    "context"
    "fmt"
    corev1 "k8s.io/api/core/v1"
    metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
    "k8s.io/client-go/kubernetes"
    "k8s.io/client-go/tools/clientcmd"
    "k8s.io/apimachinery/pkg/util/duration"
    "time"
  )
  
  // 集群外场景初始化客户端示例
  config, err := clientcmd.BuildConfigFromFlags("", "/path/to/your/kubeconfig")
  if err != nil {
    panic(err.Error())
  }
  clientset, err := kubernetes.NewForConfig(config)
  if err != nil {
    panic(err.Error())
  }
  

• 2. 筛选指定Pod的关联事件
     Kubernetes的事件是独立的corev1.Event资源，你可以通过fieldSelector过滤出和目标Pod绑定的所有事件，过滤规则需要指定关联对象的类型、名称、命名空间：

  // 替换为你的目标Pod信息
  targetPodName := "spark-t2f59"
  targetNamespace := "spark"
  
  fieldSelector := fmt.Sprintf("involvedObject.kind=Pod,involvedObject.name=%s,involvedObject.namespace=%s", targetPodName, targetNamespace)
  eventList, err := clientset.CoreV1().Events(targetNamespace).List(context.TODO(), metav1.ListOptions{
    FieldSelector: fieldSelector,
  })
  if err != nil {
    panic(err.Error())
  }
  

• 3. 格式化输出匹配kubectl效果
     按kubectl的输出规则提取对应字段，其中Age字段可以直接用K8s官方提供的duration.HumanDuration工具方法转换为可读时长，参考代码：

  // 打印表头
  fmt.Printf("%-8s %-18s %-6s %-20s %s\n", "Type", "Reason", "Age", "From", "Message")
  fmt.Printf("%-8s %-18s %-6s %-20s %s\n", "----", "------", "----", "----", "-------")
  // 遍历事件打印
  for _, event := range eventList.Items {
    age := duration.HumanDuration(time.Since(event.LastTimestamp.Time))
    fmt.Printf("%-8s %-18s %-6s %-20s %s\n", event.Type, event.Reason, age, event.Source.Component, event.Message)
  }
  

  如果你需要和kubectl完全一致的排序，将事件列表按LastTimestamp倒序排列即可。

内容的提问来源于stack exchange，提问作者javier_orta