访问kubernetes CRD的几种方式

最近在使用代码操作VictoriaMetrics Operator的CRD资源的过程中，探究了集中访问CRD资源的方式。下面以VictoriaMetrics Operator的CRD为例介绍。

方式1：使用dynamic client

这种方式最原始，使用dynamic client获取到原始的json数据，可以使用json.Unmarshal 将数据解析到结构体重，也可以 runtime.DefaultUnstructuredConverter.FromUnstructured方法进行解析。

这种方式的好处是简单好理解，缺点就是需要在json层面操作数据，使用json作为实际数据结构和unstructured.Unstructured之间的转换媒介，性能上面可能会存在一定问题。

代码如下，更多参见这篇文章。

    restConfig := &rest.Config{

       Host:            "https://xxxxx:6443",

       BearerToken:     "xxxx",

       TLSClientConfig: rest.TLSClientConfig{Insecure: true},

    }    

    dynClient, err := dynamic.NewForConfig(restConfig)

    if err != nil {

        return

    }

    var r = schema.GroupVersionResource{Group: "operator.victoriametrics.com", Version: "v1beta1", Resource: "vmrules"}

    list, err := dynClient.Resource(r).Namespace("vm").List(context.TODO(), metav1.ListOptions{})

    if err != nil {

        return

    }

    rlist := v1beta1.VMRuleList{}

    /* 可以直接使用json方式解析到结构体中

    data, _ := list.MarshalJSON()

    if err := json.Unmarshal(data, &rlist); err != nil {

        return

    }

     */

    runtime.DefaultUnstructuredConverter.FromUnstructured(list.UnstructuredContent(), &rlist)

    fmt.Println(rlist)

方式2：使用client-go

一般会采用这种方式。首先需要在restConfig中注册GroupVersion和scheme。可以使用kubectl get --raw /apis/operator.victoriametrics.com/v1beta1来验证该资源的APIPath是不"/apis"。scheme用于注册结构体信息，使用scheme生成的parameterCodec来解析数据。

代码如下：

    var SchemeGroupVersion = schema.GroupVersion{Group: "operator.victoriametrics.com", Version: "v1beta1"}

    restConfig := &rest.Config{

       Host:            "https://xxxx:6443",

       BearerToken:     "xxxx",

       TLSClientConfig: rest.TLSClientConfig{Insecure: true},

    }

    restConfig.APIPath = "/apis"

    restConfig.GroupVersion = &SchemeGroupVersion

    restConfig.NegotiatedSerializer = scheme1.Codecs.WithoutConversion()

    scheme := runtime.NewScheme()

    victoriametricsv1beta1.AddToScheme(scheme)

    parameterCodec := runtime.NewParameterCodec(scheme)

    if restConfig.UserAgent == "" {

        restConfig.UserAgent = rest.DefaultKubernetesUserAgent()

    }

    c,err := rest.RESTClientFor(restConfig)

    if nil != err{

       panic(err)

    }

    rl := &v1beta1.VMRuleList{}

    err = c.Get().

        Namespace("vm").

        Resource("vmrules").

        VersionedParams(&metav1.ListOptions{},scheme1.ParameterCodec).

        Do(context.TODO()).

        Into(rl)

    fmt.Println(err,rl)

巴特西

访问kubernetes CRD的几种方式