如何从集群内 client-go api 调用中检索 kubectl 描述 pods 的所有数据

欢迎各位小伙伴来到golang学习网，相聚于此都是缘哈哈哈！今天我给大家带来《如何从集群内 client-go api 调用中检索 kubectl 描述 pods 的所有数据》，这篇文章主要讲到等等知识，如果你对Golang相关的知识非常感兴趣或者正在自学，都可以关注我，我会持续更新相关文章！当然，有什么建议也欢迎在评论留言提出！一起学习！

我需要获取一些 pod 信息，这些信息将用于一些将在集群中运行的单元测试。我需要 kubectl 描述 po 提供的所有信息，但来自集群内 api 调用。

我有一些工作代码，可以对 apis/metrics.k8s.io/v1beta1/pods 进行 api 调用，并在 minikube 上安装了指标服务器以进行测试，该代码一切正常，并提供如下输出： p>

namespace: kube-system
pod name: heapster-rgnlj
selflink: /apis/metrics.k8s.io/v1beta1/namespaces/kube-system/pods/heapster-rgnlj
creationtimestamp: 2019-09-10 12:27:13 +0000 utc
window: 30s
timestamp: 2019-09-10 12:26:23 +0000 utc
name: heapster
cpu usage: 82166n
mem usage: 19420ki

...
func getMetrics(clientset *kubernetes.Clientset, pods *PodMetricsList) error {
    data, err := clientset.RESTClient().Get().AbsPath("apis/metrics.k8s.io/v1beta1/pods").DoRaw()
    if err != nil {
        return err
    }
    err = json.Unmarshal(data, &pods)
    return err
}

func main() {

    config, err := rest.InClusterConfig()
    if err != nil {
        fmt.Println(err)
    }
    // creates the clientset
    clientset, err := kubernetes.NewForConfig(config)
    if err != nil {
        fmt.Println(err)
    }
    var pods PodMetricsList
    err = getMetrics(clientset, &pods)
    if err != nil {
        fmt.Println(err)
    }

    for _, m := range pods.Items {

        fmt.Print("Namespace: ", m.Metadata.Namespace, "\n", "Pod name: ", m.Metadata.Name, "\n", )
        fmt.Print("SelfLink: ", m.Metadata.SelfLink, "\n", "CreationTimestamp: ", m.Metadata.CreationTimestamp, "\n", )
        fmt.Print("Window: ", m.Window, "\n", "Timestamp: ", m.Timestamp, "\n", )

        for _, c := range m.Containers {
            fmt.Println("Name:", c.Name)
            fmt.Println("Cpu usage:", c.Usage.CPU)
            fmt.Println("Mem usage:", c.Usage.Memory, "\n")
...

正如我所说，我真正需要的是通过“描述 pod”类型调用获得的结果。查看完 kubernetes 源代码后，这个 nodedescriber 看起来像是正确的函数类型，但我对如何集成/实现它以获得所需的结果有点不知所措。

kubernetes/pkg/printers/internalversion/describe.go

4f2d7b9 中的第 2451 行

func (d *nodedescriber)describe(命名空间、名称字符串、describersettings...等)

我是 go 新手，对 kubernetes 不是特别熟悉。 任何有关如何进行的指示将不胜感激。

解决方案

查看 staging/src/k8s.io/kubectl/pkg/describe/versioned/describe.go 中的 describePod 和 Describe 函数应该可以让您更好地了解如何执行此操作。由于 Describe 和 PodDescriber 是公开的，因此您可以在您的用例中重复使用它们。

您可以将其与具有 Pods 函数的 CoreV1Client 结合使用，该函数返回具有 List 函数的 PodInterface，该函数将返回给定命名空间的 Pod 个对象的列表。

这些 pod 对象将提供 Describe 函数所需的名称，命名空间已知，并且 describe.DescriberSettings 只是一个结构类型，您可以内联该结构类型以在 Describe 输出中显示事件。

使用 List 函数只会列出那一次的 Pod。如果您有兴趣定期更新此列表，您可能需要查看 Reflector 和 Informer 模式；两者主要在 tools/cache 包中实现，文档在 Efficient detection of changes 部分简要解释了这个概念。

希望这有帮助。

今天带大家了解了的相关知识，希望对你有所帮助；关于Golang的技术知识我们会一点点深入介绍，欢迎大家关注golang学习网公众号，一起学习编程~