golang metrics server 监控node和pod-Go服务器开发

Metrics Server 是 Kubernetes 集群的一个组件，用于收集和暴露各种资源的监控指标。使用 Golang 可以编写 Metrics Server 的客户端程序，来实现对 Node 和 Pod 的监控。

以下是 Golang 实现 Metrics Server 客户端程序的主要步骤：

安装 k8s.io/client-go 包

在 Golang 环境中安装 k8s.io/client-go 包，该包提供了访问 Kubernetes API Server 的客户端库。

go get k8s.io/client-go/...

使用 Heapster Metrics API 获取监控数据

通过访问 Heapster Metrics API 来获取 Node 和 Pod 的监控数据。例如，下面的代码片段演示如何获取 Node 列表和 Pod 列表，并输出其 CPU 和内存使用情况：

package main

import (
    "flag"
    "fmt"
    "time"

    "k8s.io/apimachinery/pkg/api/resource"
    metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
    "k8s.io/client-go/kubernetes"
    "k8s.io/client-go/rest"
)

func main() {
	var kubeconfig string
	flag.StringVar(&kubeconfig, "kubeconfig", "", "Path to a kubeconfig file")
	flag.Parse()

	// 初始化 Kubernetes REST Client
	config, err := clientcmd.BuildConfigFromFlags("", kubeconfig)
	if err != nil {
		panic(err.Error())
	}
	clientset, err := kubernetes.NewForConfig(config)
	if err != nil {
		panic(err.Error())
	}

	// 获取所有节点列表并输出 CPU 和内存使用情况
	nodes, err := clientset.CoreV1().Nodes().List(metav1.ListOptions{})
	if err != nil {
		panic(err.Error())
	}
	for _, node := range nodes.Items {
		nodeName := node.GetName()
		metricsClient := clientset.MetricsV1beta1().NodeMetricses()
		metrics, err := metricsClient.Get(nodeName, metav1.GetOptions{})
		if err != nil {
			panic(err.Error())
		}
		cpuUsage := metrics.Usage.Cpu()
		memoryUsage := metrics.Usage.Memory()
		fmt.Printf("Node %s: CPU usage=%s, memory usage=%s\n", nodeName, cpuUsage.String(), memoryUsage.String())
        }

    // 获取所有 Pod 列表并输出 CPU 和内存使用情况
	pods, err := clientset.CoreV1().Pods("").List(metav1.ListOptions{})
	if err != nil {
		panic(err.Error())
	}
	for _, pod := range pods.Items {
        podName := pod.GetName()
        namespaceName:=pod.GetNamespace()
        metricsClient:=clientset.MetricsV1beta1().PodMetricses(namespaceName)
        metrics,err:=metricsClient.Get(podName,metav1.GetOptions{})
        if err!=nil{
            panic(err.Error())
        }
        containers:=metrics.Containers
        for _,container:=range containers{
            cpuUsage:=container.Usage.Cpu()
            memoryUsage:=container.Usage.Memory()

            fmt.Printf("Pod %s in Namespace %s: Container %s - CPU usage=%s, memory usage=%s\n",podName,namespaceName,container.Name ,cpuUsage.String(),memoryUsage.String())

        }

	time.Sleep(10 * time.Second)
}

以上代码演示了如何使用 Golang 代码获取 Node 和 Pod 的监控指标，其中 Heapster Metrics API 在 Kubernetes 1.11 版本后已经被废弃，因此在新版本的 Kubernetes 中需要使用 Metric Server 来获取监控数据。