如何读取 Volumesnapshot 对象（或任何 K8s 对象）

Question

我想在 go 中读取和解析 Volumesnapshot 对象（或任何 K8s 对象）。我试图参考https://github.com/kubernetes/client-go。

我正在尝试将 VolumeSnapshot CRD 元数据中的自定义注释添加为

apiVersion: snapshot.storage.k8s.io/v1beta1
kind: VolumeSnapshot
metadata:
  name: new-snapshot-test
  **annotation:**
        **test:Tushar**
spec:
  volumeSnapshotClassName: csi-hostpath-snapclass
  source:
    persistentVolumeClaimName: pvc-test

我还有一个自定义 CSI 驱动程序。我需要我的 CSI 驱动程序在 K8s api 服务器中查找该 volumneSnapshot 并解析此自定义注释，然后进行相应处理。

Answer 1

您可以按照 Github 存储库 here 中的任何示例进行操作。例如使用动态/非结构化方式（基于this的代码sn-p）：

func main() {
    var kubeconfig *string
    if home := homedir.HomeDir(); home != "" {
        kubeconfig = flag.String("kubeconfig", filepath.Join(home, ".kube", "config"), "(optional) absolute path to the kubeconfig file")
    } else {
        kubeconfig = flag.String("kubeconfig", "", "absolute path to the kubeconfig file")
    }
    flag.Parse()

    namespace := "default"

    config, err := clientcmd.BuildConfigFromFlags("", *kubeconfig)
    if err != nil {
        panic(err)
    }
    client, err := dynamic.NewForConfig(config)
    if err != nil {
        panic(err)
    }

    volumesnapshotRes := schema.GroupVersionResource{Group: "snapshot.storage.k8s.io", Version: "v1beta1", Resource: "volumesnapshots"}

    // List VolumeSnapshots
    prompt()
    fmt.Printf("Listing volume snapshots in namespace %q:\n", apiv1.NamespaceDefault)
    list, err := client.Resource(volumesnapshotRes).Namespace(namespace).List(context.TODO(), metav1.ListOptions{})
    if err != nil {
        panic(err)
    }
    for _, d := range list.Items {
    ...
        // do whatever with the items (print, etc)
    }
    // Finish up
    ...