访问kubernetes|访问kubernetes CRD的几种方式访问kubernetesCRD的几种方式

访问kubernetes CRD的几种方式 【访问kubernetes|访问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)