go - 如何在golang程序中使用client-go列出k8s集群中的所有Pod？

Question

Closed. This question needs details or clarity。它当前不接受答案。












想改善这个问题吗？添加详细信息，并通过 editing this post阐明问题。

5个月前关闭。



Improve this question




我想使用go-client程序列出k8s集群中的所有Pod。
一个使用client-go列出k8s集群中所有Pod的go程序？

最佳答案

假设您正在集群中运行程序，请使用InClusterConfig，如下所示，并调用clientset.CoreV1().Pods("").List(context.TODO(), metav1.ListOptions{})。由于我们没有为命名空间传递任何值，因此它将列出所有命名空间中的所有pod。

func main() {
    // creates the in-cluster config
    config, err := rest.InClusterConfig()
    if err != nil {
        panic(err.Error())
    }
    // creates the clientset
    clientset, err := kubernetes.NewForConfig(config)
    if err != nil {
        panic(err.Error())
    }
    for {
        // get pods in all the namespaces by omitting namespace
        // Or specify namespace to get pods in particular namespace
        pods, err := clientset.CoreV1().Pods("").List(context.TODO(), metav1.ListOptions{})
        if err != nil {
            panic(err.Error())
        }
        fmt.Printf("There are %d pods in the cluster\n", len(pods.Items))

        // Examples for error handling:
        // - Use helper functions e.g. errors.IsNotFound()
        // - And/or cast to StatusError and use its properties like e.g. ErrStatus.Message
        _, err = clientset.CoreV1().Pods("default").Get(context.TODO(), "example-xxxxx", metav1.GetOptions{})
        if errors.IsNotFound(err) {
            fmt.Printf("Pod example-xxxxx not found in default namespace\n")
        } else if statusError, isStatus := err.(*errors.StatusError); isStatus {
            fmt.Printf("Error getting pod %v\n", statusError.ErrStatus.Message)
        } else if err != nil {
            panic(err.Error())
        } else {
            fmt.Printf("Found example-xxxxx pod in default namespace\n")
        }

        time.Sleep(10 * time.Second)
    }
}

关于go - 如何在golang程序中使用client-go列出k8s集群中的所有Pod？ ，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/64191539/

上一篇：go - 从核心函数获取未知类型的nil值

下一篇：http - 重试 http 请求 RoundTrip

相关文章：

go - 如何使用 client-go 列出所有具有特定标签的 kubernetes 对象

go - 使用client-go删除所有kubernetes资源？

使用 channel 进行执行控制的 GO 代码

variables - 从命令行询问两个整数 - Golang

json - 通过 STDIN/STDOUT 使用 json 的 websocketd

kubernetes - Kubernetes 如何帮助我为每个客户部署一个应用程序？

kubernetes - 无法让Metallb在我的裸机集群上工作

kubernetes - Istio交通分配未正确使用重量

删除了 golang http 响应 header

go - 在单个YAML文件中直接对多种类型的Kubernetes API使用client-go to `kubectl apply`

Answer 1

假设您正在集群中运行程序，请使用InClusterConfig，如下所示，并调用clientset.CoreV1().Pods("").List(context.TODO(), metav1.ListOptions{})。由于我们没有为命名空间传递任何值，因此它将列出所有命名空间中的所有pod。

func main() {
    // creates the in-cluster config
    config, err := rest.InClusterConfig()
    if err != nil {
        panic(err.Error())
    }
    // creates the clientset
    clientset, err := kubernetes.NewForConfig(config)
    if err != nil {
        panic(err.Error())
    }
    for {
        // get pods in all the namespaces by omitting namespace
        // Or specify namespace to get pods in particular namespace
        pods, err := clientset.CoreV1().Pods("").List(context.TODO(), metav1.ListOptions{})
        if err != nil {
            panic(err.Error())
        }
        fmt.Printf("There are %d pods in the cluster\n", len(pods.Items))

        // Examples for error handling:
        // - Use helper functions e.g. errors.IsNotFound()
        // - And/or cast to StatusError and use its properties like e.g. ErrStatus.Message
        _, err = clientset.CoreV1().Pods("default").Get(context.TODO(), "example-xxxxx", metav1.GetOptions{})
        if errors.IsNotFound(err) {
            fmt.Printf("Pod example-xxxxx not found in default namespace\n")
        } else if statusError, isStatus := err.(*errors.StatusError); isStatus {
            fmt.Printf("Error getting pod %v\n", statusError.ErrStatus.Message)
        } else if err != nil {
            panic(err.Error())
        } else {
            fmt.Printf("Found example-xxxxx pod in default namespace\n")
        }

        time.Sleep(10 * time.Second)
    }
}