如何通过K8s Golang客户端触发Pod的更新重部署操作

依赖情况说明 #

你当前引入的4个依赖已经基本覆盖触发Pod重部署的需求，如果操作的是Deployment/StatefulSet这类工作负载，仅需额外引入K8s官方标准包k8s.io/api/apps/v1，不需要引入其他第三方依赖。 #

两种实现方案说明 #

方案1：基于K8s API触发标准滚动更新（生产环境推荐） #

注意：裸Pod（未通过Deployment/StatefulSet等工作负载管理的独立Pod）不支持滚动更新，只能删除重建，生产环境几乎都是使用工作负载管理Pod，以下以最常用的Deployment为例：
实现逻辑和kubectl rollout restart deployment <deploy-name>完全一致，通过更新Deployment的Pod模板注解触发自动滚动重建：

import (
    "context"
    "time"

    v1 "k8s.io/api/core/v1"
    appsv1 "k8s.io/api/apps/v1"
    metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
    "k8s.io/client-go/kubernetes"
    "k8s.io/client-go/rest"
)

func RolloutRestartDeployment(clientset *kubernetes.Clientset, namespace, deployName string) error {
    // 获取现有Deployment
    deploy, err := clientset.AppsV1().Deployments(namespace).Get(context.TODO(), deployName, metav1.GetOptions{})
    if err != nil {
        return err
    }
    // 给Pod模板添加重启时间注解，触发滚动更新
    if deploy.Spec.Template.Annotations == nil {
        deploy.Spec.Template.Annotations = make(map[string]string)
    }
    deploy.Spec.Template.Annotations["kubectl.kubernetes.io/restartedAt"] = time.Now().Format(time.RFC3339)
    // 提交更新
    _, err = clientset.AppsV1().Deployments(namespace).Update(context.TODO(), deploy, metav1.UpdateOptions{})
    return err
}

如果是需要重建裸Pod，直接调用Pod删除接口即可，有控制器管理的Pod删除后会自动重建，无控制器管理的独立裸Pod删除后需要自行调用创建接口重建：

err := clientset.CoreV1().Pods(namespace).Delete(context.TODO(), podName, metav1.DeleteOptions{})

方案2：发送Linux信号实现（仅适合特定场景） #

这种方案可以实现，但有明显局限性，不推荐作为生产级重部署方案：

• 前提要求：
  • 你的应用进程本身支持处理对应信号（比如SIGHUP）实现配置重载/重启逻辑
  • 客户端有权限调用Pod的exec接口进入容器执行信号发送命令
• 缺陷：
  • 多Pod场景需要逐个发送信号，无法实现滚动更新的零停机保障
  • 新扩容的Pod不会自动继承信号操作，需要重复执行
  • 依赖容器内的进程信号处理逻辑，通用性差
    实现同样不需要额外依赖，调用clientset.CoreV1().Pods(namespace).Exec接口发送kill -HUP <pid>命令即可。

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