k8s中如何获取pv的大小示例-Go服务器开发

在 Kubernetes 中，可以通过以下方法获取 PersistentVolume（PV）的大小：

使用 kubectl 命令：

kubectl get pv <pv-name> -o jsonpath='{.spec.capacity.storage}'

其中，<pv-name> 为目标 PV 的名称。该命令将返回 PV 的存储容量（例如 10Gi）。

使用 Kubernetes Go Client Library：

package main
import (
	"fmt"
	"k8s.io/client-go/tools/clientcmd"
	"k8s.io/client-go/kubernetes"
	"k8s.io/client-go/util/homedir"
	"path/filepath"
	v1 "k8s.io/api/core/v1"
	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
)
func main() {
    // 获取 kubeconfig 文件路径
	var kubeconfig string
	if home := homedir.HomeDir(); home != "" {
		kubeconfig = filepath.Join(home, ".kube", "config")
	} else {
		panic("unable to get home directory")
	}
    // 加载 kubeconfig 文件并创建客户端
	config, err := clientcmd.BuildConfigFromFlags("", kubeconfig)
	if err != nil {
        panic(err.Error())
    }
	clientset, err := kubernetes.NewForConfig(config)
	if err != nil {
        panic(err.Error())
    }
    // 获取指定的 PV 对象
	pvName := "<pv-name>"
	pvObj, err := clientset.CoreV1().PersistentVolumes().Get(pvName, metav1.GetOptions{})
	if err != nil {
        panic(err.Error())
    }
    // 获取 PV 的存储容量
	pvCapacity := pvObj.Spec.Capacity[v1.ResourceStorage]
	fmt.Printf("%s: %d\n", pvName, pvCapacity.Value())
}

上述代码中，我们首先加载了本地的 kubeconfig 文件，并使用该文件中包含的配置信息创建了 Kubernetes 客户端。然后，我们调用了 clientset.CoreV1().PersistentVolumes().Get() 方法来获取指定名称的 PV 对象，并从该对象的 Spec.Capacity 字段中获取存储容量。需要注意的是，这里返回的存储容量单位为字节，因此需要根据需要进行转换（例如转换成 GiB）。