如何使用client-go库列出与持久卷声明相关联的Pod？

huangapple
go评论121阅读模式
英文:

How to list Pods which are associated with persistent volume claim using client-go library?

问题

使用以下的client-go调用来列出特定命名空间中的PVC。

  1. x, err := clientset.CoreV1().PersistentVolumeClaims("namespace_name").List(context.TODO(), metav1.ListOptions{})

我们如何获取与PVC相关联的Pod列表？

英文:

Using below client-go call to list PVC in a particular namespace.

  1. x, err := clientset.CoreV1().PersistentVolumeClaims("namespace_name").List(context.TODO(), metav1.ListOptions{})

How we can get a list of Pods associated with PVC?

答案1

得分: 0

似乎我们需要使用循环和过滤来定位使用特定 PVC 的 Pod。以下是一个简单的代码示例，它将遍历特定命名空间中的 Pod，将具有 PVC 的 Pod 保存到新列表中并打印出来：

  1. // 设置命名空间
  2. var namespace = "default"
  4. // 获取 Pod 列表
  5. podList, _ := clientset.CoreV1().Pods(namespace).List(context.TODO(), metav1.ListOptions{})
  7. // 创建新的 Pod 列表
  8. podsWithPVC := &corev1.PodList{}
  10. // 过滤 Pod，检查是否存在 PVC，如果存在则添加到列表中
  11. for _, pod := range podList.Items {
  12.         for _, volume := range pod.Spec.Volumes {
  13.                 if volume.PersistentVolumeClaim != nil {
  14.                         podsWithPVC.Items = append(podsWithPVC.Items, pod)
  15.                         fmt.Println("Pod Name: " + pod.GetName())
  16.                         fmt.Println("PVC Name: " + volume.PersistentVolumeClaim.ClaimName)
  17.                 }
  18.         }
  19. }

完整的代码示例（基于此代码）：

  1. package main
  3. import (
  4.         "context"
  5.         "flag"
  6.         "fmt"
  7.         "path/filepath"
  9.         corev1 "k8s.io/api/core/v1"
  10.         metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
  11.         "k8s.io/client-go/kubernetes"
  12.         "k8s.io/client-go/tools/clientcmd"
  13.         "k8s.io/client-go/util/homedir"
  14. )
  16. func main() {
  18.         var kubeconfig *string
  19.         if home := homedir.HomeDir(); home != "" {
  20.                 kubeconfig = flag.String("kubeconfig", filepath.Join(home, ".kube", "config"), "(optional) absolute path to the kubeconfig file")
  21.         } else {
  22.                 kubeconfig = flag.String("kubeconfig", "", "absolute path to the kubeconfig file")
  23.         }
  24.         flag.Parse()
  26.         config, err := clientcmd.BuildConfigFromFlags("", *kubeconfig)
  27.         if err != nil {
  28.                 panic(err)
  29.         }
  30.         clientset, err := kubernetes.NewForConfig(config)
  31.         if err != nil {
  32.                 panic(err)
  33.         }
  35.         // 设置命名空间
  36.         var namespace = "default"
  38.         // 获取 Pod 列表
  39.         podList, _ := clientset.CoreV1().Pods(namespace).List(context.TODO(), metav1.ListOptions{})
  41.         // 创建新的 Pod 列表
  42.         podsWithPVC := &corev1.PodList{}
  44.         // 过滤 Pod，检查是否存在 PVC，如果存在则添加到列表中
  45.         for _, pod := range podList.Items {
  46.                 for _, volume := range pod.Spec.Volumes {
  47.                         if volume.PersistentVolumeClaim != nil {
  48.                                 podsWithPVC.Items = append(podsWithPVC.Items, pod)
  49.                                 fmt.Println("Pod Name: " + pod.GetName())
  50.                                 fmt.Println("PVC Name: " + volume.PersistentVolumeClaim.ClaimName)
  51.                         }
  52.                 }
  53.         }
  54. }
英文:

It seems that we need to use loop and filtering - similar question on the GitHub:
>No, looping and filtering is the only way to locate pods using a specific PVC

Simple code that will go through pods in specific namespace, save pods with PVC to new list and print:

  1. // Set namespace
  2. var namespace = "default"
  4. // Get pods list
  5. podList, _ := clientset.CoreV1().Pods(namespace).List(context.TODO(), metav1.ListOptions{})
  7. // Create new pod list
  8. podsWithPVC := &corev1.PodList{}
  10. // Filter pods to check if PVC exists, if yes append to the list
  11. for _, pod := range podList.Items {
  12.         for _, volume := range pod.Spec.Volumes {
  13.                 if volume.PersistentVolumeClaim != nil {
  14.                         podsWithPVC.Items = append(podsWithPVC.Items, pod)
  15.                         fmt.Println("Pod Name: " + pod.GetName())
  16.                         fmt.Println("PVC Name: " + volume.PersistentVolumeClaim.ClaimName)
  17.                 }
  18.         }
  19. }

Whole code (based on this code):

  1. package main
  3. import (
  4.         "context"
  5.         "flag"
  6.         "fmt"
  7.         "path/filepath"
  9.         corev1 "k8s.io/api/core/v1"
  10.         metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
  11.         "k8s.io/client-go/kubernetes"
  12.         "k8s.io/client-go/tools/clientcmd"
  13.         "k8s.io/client-go/util/homedir"
  14. )
  16. func main() {
  18.         var kubeconfig *string
  19.         if home := homedir.HomeDir(); home != "" {
  20.                 kubeconfig = flag.String("kubeconfig", filepath.Join(home, ".kube", "config"), "(optional) absolute path to the kubeconfig file")
  21.         } else {
  22.                 kubeconfig = flag.String("kubeconfig", "", "absolute path to the kubeconfig file")
  23.         }
  24.         flag.Parse()
  26.         config, err := clientcmd.BuildConfigFromFlags("", *kubeconfig)
  27.         if err != nil {
  28.                 panic(err)
  29.         }
  30.         clientset, err := kubernetes.NewForConfig(config)
  31.         if err != nil {
  32.                 panic(err)
  33.         }
  35.         // Set namespace
  36.         var namespace = "default"
  38.         // Get pods list
  39.         podList, _ := clientset.CoreV1().Pods(namespace).List(context.TODO(), metav1.ListOptions{})
  41.         // Create new pod list
  42.         podsWithPVC := &corev1.PodList{}
  44.         // Filter pods to check if PVC exists, if yes append to the list
  45.         for _, pod := range podList.Items {
  46.                 for _, volume := range pod.Spec.Volumes {
  47.                         if volume.PersistentVolumeClaim != nil {
  48.                                 podsWithPVC.Items = append(podsWithPVC.Items, pod)
  49.                                 fmt.Println("Pod Name: " + pod.GetName())
  50.                                 fmt.Println("PVC Name: " + volume.PersistentVolumeClaim.ClaimName)
  51.                         }
  52.                 }
  53.         }
  54. }

huangapple
  • 本文由 发表于 2022年1月19日 19:13:34
  • 转载请务必保留本文链接：https://go.coder-hub.com/70769569.html
  • client-go
  • go
  • kubernetes
匿名

发表评论

匿名网友

:?: :razz: :sad: :evil: :!: :smile: :oops: :grin: :eek: :shock: :???: :cool: :lol: :mad: :twisted: :roll: :wink: :idea: :arrow: :neutral: :cry: :mrgreen:

确定