如何使用 client-go 访问 service.yaml 中的 metadata.labels.{custom_field}？

Question

我目前正在使用 Go 进行一个副项目。我正在尝试获取有关集群上 pods 运行的信息。

我可以根据命名空间值到达 pods，但是为了使用 service.yaml 文件中的 metadata.labels.applicationGroup 值到达工作 pods，我需要先获取这个值

我在下面添加了我的 service.yaml 文件的一部分。

---
apiVersion: apps/v1
kind: Deployment
metadata:
  name: metadata-name
  labels:
    service: service-name
    applicationGroup: beta --> this field
spec:
  replicas: 1
  selector:
    matchLabels:
      service: service-name
  template:
    metadata:
      labels:
        service: service-name
    spec:
      containers:
      - name: nginx
        image: nginx:1.15.8
        ports:
        - containerPort: 80
...

现在，我可以使用“默认”命名空间访问信息 pods。

func getPodsInfo() (string, error) {

  var kubeConfig *string

  if home := homedir.HomeDir(); home != "" {
    kubeConfig = flag.String("kubeConfig", filepath.Join(home, ".kube", "config"), "(optional) absolute path to the kubeConfig file")
  } else {
    kubeConfig = flag.String("kubeConfig", "", "absolute path to the kubeConfig file")
  }
  flag.Parse()

  config, err := clientcmd.BuildConfigFromFlags("", *kubeConfig)
  if err != nil {
    err = fmt.Errorf("error occured when build config from flags: %s", err.Error())
    return "", err
  }

  clientSet, err := kubernetes.NewForConfig(config)
  if err != nil {
    err = fmt.Errorf("error occured when build client set from config: %s", err.Error())
    return "", err
  }
  /*
    listOptions := meta.ListOptions{
      FieldSelector: "metadata.labels.applicationGroup=alpha",
    }
  */
  pods, err := clientSet.CoreV1().Pods("default").List(context.TODO(), metav1.ListOptions{})
  if err != nil {
    err = fmt.Errorf("error occured when get pods info from k8s: %s", err.Error())
    return "", err
  }

  podsInfo, err := json.Marshal(&pods)
  if err != nil {
    err = fmt.Errorf("error occured when json marshal: %s", err.Error())
    return "", err
  }

  return string(podsInfo), nil
}

我试过FieldSelector，但是FieldSelector已经支持了一些字段。

listOptions := meta.ListOptions{
    FieldSelector: "metadata.labels.applicationGroup=alpha",
}

我收到以下错误。

field label not supported: metadata.labels.applicationGroup

您可以查看此 link 以了解支持的字段。

关于我的问题，我怎样才能用 cilent_go 达到 metadata.labels.applicationGroup 值，我应该使用哪个函数来达到 pods 使用这个值？

Answer 1

只需使用 LabelSelector 而不是 FieldSelector

listOptions := meta.ListOptions{
    LabelSelector: "applicationGroup=alpha",
}

UPD：如果你想将它用于 pods，你应该在 pod 模板上设置 applicationGroup

apiVersion: apps/v1
kind: Deployment
metadata:
  name: metadata-name
  labels:
    service: service-name
spec:
  replicas: 1
  selector:
    matchLabels:
      service: service-name
  template:
    metadata:
      labels:
        service: service-name
        applicationGroup: beta
    spec:
      containers:
      - name: nginx
        image: nginx:1.15.8
        ports:
        - containerPort: 80

如何使用 client-go 访问 service.yaml 中的 metadata.labels.{custom_field}？

How to access metadata.labels.{custom_field} in service.yaml with client-go?

go

kubernetes

yaml

devops