如何让序列化的Kubernetes资源自动包含Group/Version/Kind？

你当前的代码在序列化corev1.Namespace对象时缺少apiVersion和kind字段，虽然手动设置TypeMeta可以解决，但希望能从类型本身自动推导这些信息，无需硬编码。以下是两种可行的实现方式：

方法一：通过Scheme获取对象的GVK并自动设置TypeMeta #

利用scheme.Scheme.ObjectKinds()方法可以获取对象对应的GroupVersionKind（GVK）信息，然后将其填充到对象的TypeMeta中，无需手动指定：

package main

import (
    "os"

    corev1 "k8s.io/api/core/v1"
    metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
    "k8s.io/apimachinery/pkg/runtime/serializer/json"
    "k8s.io/kubectl/pkg/scheme"
)

func main() {
    corev1.AddToScheme(scheme.Scheme)

    serializer := json.NewSerializerWithOptions(
        json.DefaultMetaFactory, scheme.Scheme, scheme.Scheme,
        json.SerializerOptions{
            Pretty: true,
            Yaml:   true,
            Strict: true,
        })

    namespace := corev1.Namespace{
        ObjectMeta: metav1.ObjectMeta{
            Name: "example",
        },
    }

    // 通过Scheme获取对象的GVK并设置TypeMeta
    gvks, _, err := scheme.Scheme.ObjectKinds(&namespace)
    if err != nil {
        panic(err)
    }
    if len(gvks) > 0 {
        namespace.TypeMeta.APIVersion = gvks[0].GroupVersion().String()
        namespace.TypeMeta.Kind = gvks[0].Kind
    }

    if err := serializer.Encode(&namespace, os.Stdout); err != nil {
        panic(err)
    }
}

方法二：通过Scheme直接创建带有TypeMeta的对象 #

使用scheme.Scheme.New()方法，传入目标对象的GVK，直接创建已填充好TypeMeta的对象实例：

package main

import (
    "os"

    corev1 "k8s.io/api/core/v1"
    metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
    "k8s.io/apimachinery/pkg/runtime/serializer/json"
    "k8s.io/kubectl/pkg/scheme"
)

func main() {
    corev1.AddToScheme(scheme.Scheme)

    serializer := json.NewSerializerWithOptions(
        json.DefaultMetaFactory, scheme.Scheme, scheme.Scheme,
        json.SerializerOptions{
            Pretty: true,
            Yaml:   true,
            Strict: true,
        })

    // 通过Scheme创建带有TypeMeta的Namespace对象
    obj, err := scheme.Scheme.New(corev1.SchemeGroupVersion.WithKind("Namespace"))
    if err != nil {
        panic(err)
    }
    namespace := obj.(*corev1.Namespace)
    namespace.ObjectMeta.Name = "example"

    if err := serializer.Encode(namespace, os.Stdout); err != nil {
        panic(err)
    }
}

原理说明 #

Kubernetes的scheme中注册了所有API类型的GVK映射关系，通过上述方法可以从scheme中自动获取对应类型的apiVersion和kind，避免了硬编码带来的维护问题。两种方法都能实现自动推导，你可以根据代码场景选择更合适的方式。

内容的提问来源于stack exchange，提问作者larsks