在Kubernetes Pod中通过Go SDK实现类似kubectl apply的配置应用

其实kubectl本身就是基于client-go开发的，所以你完全可以在Pod里通过Go SDK实现和kubectl apply一致的效果，甚至能做更定制化的扩展。下面是具体的实现思路和关键步骤：

核心实现方式 #

1. 解析YAML配置文件 #

首先你需要把从GitHub拉取的YAML文件解析成Kubernetes的runtime.Object（这是client-go中代表K8s资源的通用接口）。可以用client-go的yaml包配合scheme来完成：

import (
    "bytes"
    "os"
    "k8s.io/apimachinery/pkg/runtime"
    "k8s.io/apimachinery/pkg/runtime/serializer/yaml"
    "k8s.io/client-go/kubernetes/scheme"
)

func parseYAML(filename string) (runtime.Object, error) {
    data, err := os.ReadFile(filename)
    if err != nil {
        return nil, err
    }

    decoder := yaml.NewYAMLOrJSONDecoder(bytes.NewReader(data), 4096)
    obj, _, err := decoder.Decode(nil, nil)
    if err != nil {
        return nil, err
    }
    return obj, nil
}

2. 实现Apply逻辑 #

目前有两种主流方式实现apply的效果：

方式一：使用Server-Side Apply（推荐）

这是Kubernetes 1.19+支持的特性，由服务器端负责处理资源的合并逻辑，比客户端侧的合并更可靠，还能跟踪字段归属。你可以用client-go的Apply方法：

import (
    "context"
    appsv1 "k8s.io/api/apps/v1"
    "k8s.io/client-go/kubernetes"
    applyv1 "k8s.io/client-go/applyconfigurations/apps/v1"
    metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
)

func applyDeployment(clientset *kubernetes.Clientset, obj runtime.Object) error {
    // 这里以Deployment为例，你可以根据解析出的资源类型做对应处理
    deployApplyCfg, err := applyv1.ExtractDeployment(obj, scheme.Scheme)
    if err != nil {
        return err
    }

    _, err = clientset.AppsV1().Deployments(deployApplyCfg.Namespace).Apply(
        context.TODO(),
        deployApplyCfg,
        metav1.ApplyOptions{FieldManager: "my-github-webhook-controller", Force: true},
    )
    return err
}

FieldManager参数很重要，它用来标识是哪个组件在管理资源的字段，避免不同组件修改同一字段时产生冲突。

方式二：使用Strategic Merge Patch（传统kubectl apply方式）

如果需要兼容旧版本Kubernetes，可以用这种方式：先获取资源当前的状态，然后生成合并后的补丁，再调用Patch接口：

import (
    "context"
    "encoding/json"
    appsv1 "k8s.io/api/apps/v1"
    "k8s.io/apimachinery/pkg/types"
    "k8s.io/client-go/kubernetes"
    "k8s.io/apimachinery/pkg/runtime"
    "k8s.io/apimachinery/pkg/util/strategicpatch"
    metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
)

func strategicMergePatch(clientset *kubernetes.Clientset, obj runtime.Object) error {
    // 假设是Deployment资源，先获取现有资源
    deploy := obj.(*appsv1.Deployment)
    existingDeploy, err := clientset.AppsV1().Deployments(deploy.Namespace).Get(context.TODO(), deploy.Name, metav1.GetOptions{})
    if err != nil {
        // 如果资源不存在，直接创建
        _, err = clientset.AppsV1().Deployments(deploy.Namespace).Create(context.TODO(), deploy, metav1.CreateOptions{})
        return err
    }

    // 生成双向合并补丁
    existingData, err := json.Marshal(existingDeploy)
    if err != nil {
        return err
    }
    newData, err := json.Marshal(deploy)
    if err != nil {
        return err
    }
    patch, err := strategicpatch.CreateTwoWayMergePatch(existingData, newData, appsv1.Deployment{})
    if err != nil {
        return err
    }

    // 应用补丁到集群
    _, err = clientset.AppsV1().Deployments(deploy.Namespace).Patch(context.TODO(), deploy.Name, types.StrategicMergePatchType, patch, metav1.PatchOptions{})
    return err
}

关键注意事项 #

• 权限配置：你的Pod所使用的ServiceAccount必须拥有对应资源的create、update、patch权限，需要通过Role和RoleBinding（或ClusterRole/ClusterRoleBinding）来配置，否则API调用会被拒绝。
• 资源类型处理：上面的示例只针对Deployment，你需要根据解析出的资源类型（比如Service、Ingress等）调用对应的client-go接口，可以用runtime.Object的类型断言或者scheme来动态处理多类型资源。
• 错误处理：实际代码中要完善错误处理，比如资源不存在时的创建逻辑、补丁生成失败的降级处理等。

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