前往小程序,Get更优阅读体验!
立即前往
发布
社区首页 >专栏 >访问kubernetes CRD的几种方式

访问kubernetes CRD的几种方式

作者头像
charlieroro
发布2021-11-11 14:26:45
发布2021-11-11 14:26:45
91700
代码可运行
举报
文章被收录于专栏:charlierorocharlieroro
运行总次数:0
代码可运行

访问kubernetes CRD的几种方式

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

方式1:使用dynamic client

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

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

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

代码语言:javascript
代码运行次数:0
复制
    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中注册GroupVersionscheme。可以使用kubectl get --raw /apis/operator.victoriametrics.com/v1beta1来验证该资源的APIPath是不"/apis"。scheme用于注册结构体信息,使用scheme生成的parameterCodec来解析数据。

代码如下:

代码语言:javascript
代码运行次数:0
复制
    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)
本文参与 腾讯云自媒体同步曝光计划,分享自作者个人站点/博客。
原始发表:2021-11-10 ,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体同步曝光计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
  • 访问kubernetes CRD的几种方式
    • 方式1:使用dynamic client
    • 方式2:使用client-go
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档