使用 go-client 连接 Kubernetes 中的 Pod

怎么入门Golang编程？需要学习哪些知识点？这是新手们刚接触编程时常见的问题；下面golang学习网就来给大家整理分享一些知识点，希望能够给初学者一些帮助。本篇文章就来介绍《使用 go-client 连接 Kubernetes 中的 Pod》，涉及到，有需要的可以收藏一下

我正在使用 go-client 访问我的环境中的 k8s 资源。有 API 可以获取/列出 pod、命名空间等。

如何访问当前正在运行的 Pod？

正确答案

您可以使用 pod fields 拨打 Expose Pod Information to Containers Through Environment Variables：

apiversion: v1
kind: pod
metadata:
  name: dapi-envars-fieldref
spec:
  containers:
    - name: test-container
      ...
      ...
      env:
        - name: my_node_name
          valuefrom:
            fieldref:
              fieldpath: spec.nodename
        - name: my_pod_name
          valuefrom:
            fieldref:
              fieldpath: metadata.name
        - name: my_pod_namespace
          valuefrom:
            fieldref:
              fieldpath: metadata.namespace
        - name: my_pod_ip
          valuefrom:
            fieldref:
              fieldpath: status.podip
        - name: my_pod_service_account
          valuefrom:
            fieldref:
              fieldpath: spec.serviceaccountname
  restartpolicy: never

然后只需在 go 代码中查找这些环境变量即可：

log.printf("my_pod_name: %q", os.getenv("my_pod_name"))

kubernetes client-go 提供了访问 pod 的 api，corev1 包提供了获取所有 pod 的 api 请参阅文档 https://pkg.go.dev/k8s.io/client-go/kubernetes/typed/core/v1#CoreV1Client.Pods

您可以通过命名空间、标签或查询轻松过滤或获取 pod，

查看示例代码以获取命名空间中的所有 pod。

config, err := clientcmd.buildconfigfromflags("", "path to cluster config yaml")
  clientset, err := kubernetes.newforconfig(config)
  if err != nil {
     panic(err.error())
  }
  // get all pods in namespace
  pods, err := clientset.corev1().pods("nanespace").list(context.todo(), 
  metav1.listoptions{})
  if err != nil {
          panic(err.error())
  }

请参阅使用标签获取 pod 的示例代码：

labal := fmt.Sprintf("LABLE-NAME=%s", "SOME LABEL VALUE")
    ap1 := sm.clientset.CoreV1()
    pods, _ := ap1.Pods(namespace).List(context.Background(), 
         metav1.ListOptions{LabelSelector: labal})
    pods_num := len(pods.Items)
    fmt.Printf("Found the following number of Pods: %d\n", pods_num)
    for i, pod := range pods.Items {
        fmt.Printf("[%2d] %s, Phase: %s, Created: %s, HostIP: %s\n", i, 
              pod.GetName(), string(pod.Status.Phase), 
              pod.GetCreationTimestamp(), 
              string(pod.Status.HostIP))
     }

今天关于《使用 go-client 连接 Kubernetes 中的 Pod》的内容介绍就到此结束，如果有什么疑问或者建议，可以在golang学习网公众号下多多回复交流；文中若有不正之处，也希望回复留言以告知！