解析 YAML 清单为 Kubernetes client.Object

哈喽！大家好，很高兴又见面了，我是golang学习网的一名作者，今天由我给大家带来一篇《解析 YAML 清单为 Kubernetes client.Object》，本文主要会讲到等等知识点，希望大家一起学习进步，也欢迎大家关注、点赞、收藏、转发! 下面就一起来看看吧！

我有一个 yaml 文件，定义了多个不同类型的 kubernetes 资源（根据 yaml 规范，用 --- 分隔）：

apiversion: apiextensions.k8s.io/v1
kind: customresourcedefinition
metadata:
  # ...
spec:
  # ...
---
apiversion: rbac.authorization.k8s.io/v1
kind: clusterrole
metadata:
  # ...
rules:
  # ...
---
# etc

现在，我想将此列表解析为 client.object 实例的切片，以便我可以应用一些过滤和转换，并最终使用将它们发送到集群

myclient.patch( # myclient is a client.client instance
  ctx,
  object,       # object needs to be a client.object
  client.apply,
  client.forceownership,
  client.fieldowner("my.operator.acme.inc"),
)

但是，我一生都无法弄清楚如何从 yaml 文档到 []client.object。以下内容让我几乎到达那里：

results := make([]client.Object, 0)

scheme := runtime.NewScheme()
clientgoscheme.AddToScheme(scheme)
apiextensionsv1beta1.AddToScheme(scheme)
apiextensionsv1.AddToScheme(scheme)

decode := serializer.NewCodecFactory(scheme).UniversalDeserializer().Decode
data, err := ioutil.ReadAll(reader)
if err != nil {
    return nil, err
}
for _, doc := range strings.Split(string(data), "---") {
    object, gvk, err := decode([]byte(doc), nil, nil)
    if err != nil {
        return nil, err
    }

    // object is now a runtime.Object, and gvk is a schema.GroupVersionKind
    // taken together, they have all the information I need to expose a
    // client.Object (I think) but I have no idea how to actually construct a
    // type that implements that interface

    result = append(result, ?????)

}

return result, nil

当然，我对其他解析器实现完全开放，但我还没有发现任何能让我更进一步的东西。但这似乎一定是 kubernetes 世界中一个已解决的问题......那么我该怎么做呢？

正确答案

我终于能够让它发挥作用了！方法如下：

import (
    "k8s.io/client-go/kubernetes/scheme"
    "sigs.k8s.io/controller-runtime/pkg/client"

    apiextensionsv1 "k8s.io/apiextensions-apiserver/pkg/apis/apiextensions/v1"
    apiextensionsv1beta1 "k8s.io/apiextensions-apiserver/pkg/apis/apiextensions/v1beta1"
)

func deserialize(data []byte) (*client.Object, error) {
    apiextensionsv1.AddToScheme(scheme.Scheme)
    apiextensionsv1beta1.AddToScheme(scheme.Scheme)
    decoder := scheme.Codecs.UniversalDeserializer()

    runtimeObject, groupVersionKind, err := decoder.Decode(data, nil, nil)
    if err != nil {
        return nil, err
    }

    return runtime
}

有几件事看起来很关键（但我不确定我的理解是否 100% 正确）：

• 虽然 decoder.decode 声明的返回类型是 (runtime.object, *scheme.groupversionkind, error)，但该元组返回的第一项实际上是 client.object 并且可以毫无问题地进行转换。
• 通过在添加 apiextensions.k8s.io 组之前使用 scheme.scheme 作为基准，我可以免费注册所有“标准”资源。
• 如果我使用 scheme.codecs.universaldecoder()，我会收到有关 的错误，没有为方案“pkg/runtime/scheme.go”中组“apiextensions.k8s.io”的内部版本注册任何“customresourcedefinition” :100"，返回的 groupversionkind 实例显示 __internal 版本。不知道为什么会发生这种情况，也不知道为什么当我使用 universaldeserializer() 时却不会发生这种情况。

文中关于的知识介绍，希望对你的学习有所帮助！若是受益匪浅，那就动动鼠标收藏这篇《解析 YAML 清单为 Kubernetes client.Object》文章吧，也可关注golang学习网公众号了解相关技术文章。