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

Question

我使用的是AWS的EKS，它是Kubernetes v1.10，我使用的客户端是go v7.0.0。

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

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

我已经看到了一些关于像clientset.RESTClient().Put().Body(obj).Do()这样的通用RESTClient的代码，但这不起作用，我无法理解。

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

Answer 1

如果您有一个"通用的"；runtime.Object，您可以在客户端go中使用动态客户端。动态客户端处理unstructured.Unstructured对象，所有runtime.Object都可以转换为它

// 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

您需要动态客户端来实现这一点是正确的，但要在运行时保持通用性。对象，您需要使用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{})