如何使用 client-go 向 Kubernetes API 提交通用“runtime.Object”

Question

我正在使用 AWS 的 EKS，它是 Kubernetes v1.10，我正在使用 client-go v7.0.0。

我要做的是解析一个文件中包含多个 Kubernetes 资源定义的 .yml 文件，并将这些资源提交给 Kubernetes API。我可以使用此代码 scheme.Codecs.UniversalDeserializer().Decode 成功解析文件，并返回一个 runtime.Object 数组。

我知道所有的 Kubernetes 资源都符合runtime.Object 接口，但是我找不到将通用接口提交给 API 的方法。我见过的大多数方法都使用具体类型的方法，如 Deployment、Pod 等。

我已经看到了一些围绕通用 RESTClient 的代码，例如 clientset.RESTClient().Put().Body(obj).Do()，但这不起作用，我无法弄清楚。

我知道我的客户端配置正确，因为我可以成功列出所有 Pod。

Answer 1

如果你有一个“通用”runtime.Object，你可以在 client-go 中使用dynamic client。动态客户端处理unstructured.Unstructured 对象，所有runtime.Objects 都可以转换为它。这是一个例子：

// create the dynamic client from kubeconfig
dynamicClient, err := dynamic.NewForConfig(kubeconfig)
if err != nil {
    return err
}

// convert the runtime.Object to unstructured.Unstructured
unstructuredObj, err := runtime.DefaultUnstructuredConverter.ToUnstructured(obj)
if err != nil {
    return err
}

// create the object using the dynamic client
nodeResource := schema.GroupVersionResource{Version: "v1", Resource: "Node"}
createdUnstructuredObj, err := dynamicClient.Resource(nodeResource).Namespace(ns).Create(unstructuredObj)
if err != nil {
    return err
}

// convert unstructured.Unstructured to a Node
var node *corev1.Node
if err = runtime.DefaultUnstructuredConverter.FromUnstructured(createdUnstructuredObj, node); err != nil {
    return err
}

Answer 2

您需要动态客户端是正确的，但要保持通用与 runtime.Object 一起工作，您需要使用 DiscoveryRESTMapper，它需要使用类型化客户端来发现可用的 api 版本：

dynClient, err := dynamic.NewForConfig(config)
...
clientset, err := kubernetes.NewForConfig(config)
...
gvk := obj.GroupVersionKind()
gk := schema.GroupKind{Group: gvk.Group, Kind: gvk.Kind}
groupResources, err := restmapper.GetAPIGroupResources(clientset.Discovery())
...
rm := restmapper.NewDiscoveryRESTMapper(groupResources)
mapping, err := rm.RESTMapping(gk, gvk.Version)
...
dynClient.Resource(mapping.Resource).Namespace("default").Create(obj, metav1.CreateOptions{})