13

使用 kubernetes go-client ( k8s.io/client-go/kubernetes),我知道如何获取pod.Status并且发现pod.Status.Phase有用 ( docs )。例如,我可以使用以下命令输出所有 Pod 的 Pod 状态阶段:

    ...
    api := clientset.CoreV1()
    pods, err := api.Pods("").List(metav1.ListOptions{})
    for i, pod := range pods.Items {
        podstatusPhase := string(pod.Status.Phase)
        podCreationTime := pod.GetCreationTimestamp()
        age := time.Since(podCreationTime.Time).Round(time.Second)

        podInfo := fmt.Sprintf("[%d] Pod: %s, Phase: %s , Created: %s, Age: %s", i, pod.GetName(), podstatusPhase, podCreationTime, age.String())
        fmt.Println(podInfo)
    }

但是,phase它有点简单,因为它只显示 5 个值(PendingRunningSucceededFailedUnknown)。我宁愿获得与kubectl get podsStatus 列中相同的信息,例如:

$ kubectl get pods

NAME                                        READY   STATUS              RESTARTS   AGE     IP             NODE                           NOMINATED NODE   READINESS GATES
moby-dick-cron-scheduler-1564578660-bg4sb   0/2     ContainerCreating   0          178m    <none>         ip-10-30-13-151.ec2.internal   <none>           <none>
notifications-missed-calls-1564564740-js762 0/2     Init:0/1            0          6h49m   <none>         ip-10-30-13-6.ec2.internal     <none>           <none>
antivirus-scanner-cron-1564576740-sd6hh     0/2     Completed           0          3h30m   10.30.13.169   ip-10-30-13-151.ec2.internal   <none>           <none>

Init:0/1特别是,我对PodInitializing状态感兴趣。处于这些状态的 Pod 在使用 时只会显示为“Pending” pod.Status.Phase

  • Init:0/1表示 Pod 有 1 个 Init 容器,到目前为止 0 个已成功完成。init 容器在应用容器启动之前运行。
  • PodInitializing表示 Pod 已经完成了 Init Containers 的执行。

有没有办法获得状态,例如Init:0/1using k8s.io/client-go/kubernetes?还是没有捷径,我需要像 kubectl 一样重新计算它?我猜它使用 Pod 状态条件容器状态来构建信息。如果我需要重新计算它,也许我可以使用kubectl 源代码?有谁知道我在哪里可以找到相关位?(我的golang经验非常有限)

4

3 回答 3

8

简短的回答通常是您不必在客户端计算“状态”,因为它是在服务器级别计算的。

为了显示:

您尝试使用的标准打印方式kubectl get pods,在 Kubernetes 代码库中称为Human Readable。此方法使用ServerPrint,默认为Kubernetes TablePrinterTablePrinter 类型在此处定义。

如您所见,PrintObjTablePrinter 的功能在此处被委托,但该委托来自于配置 HumanPrintFlags 并保存原始打印机

此外,您在humanreadable_glags.go中看到它包括k8s.io/cli-runtime/pkg/printers,并且您看到它正在实例化一个k8s.io/kubernetes/pkg/printers.

被调用的实际打印函数是这个PrintObj,您可以看到它处理 3 种情况,因为在某些情况下服务器返回一个表,而有些则不返回(看起来像 < 1.16 情况)。

您还可以看到,在上述情况下,没有使用https://github.com/kubernetes/kubernetes/tree/master/pkg/printers/internalversion中的代码,因此计算发生在 kube-apiserver 端之后。

请记住,这是人类可读打印机,此处定义了其他类型的打印机(取决于选项):https ://github.com/kubernetes/kubernetes/tree/master/staging/src/k8s.io/cli -运行时/pkg/打印机

于 2019-08-01T23:54:36.087 回答
2

我认为您需要重新计算它。看到这个

于 2019-08-01T01:34:21.737 回答
1

你应该使用restClient来获取原始表输出 接收资源作为表

计算比你想象的要复杂,就像Age字段一样,在 kubernetes 中,代码: func HumanDuration(d time.Duration) string {...}

于 2021-11-15T16:32:58.137 回答