如何通过Kubernetes client-go优雅终止Pod使其状态变为Completed

问题根因 #

1. Pod的status.phase是Kubernetes系统的只读推导字段，由kubelet根据Pod内所有容器的实际运行状态自动计算更新，不支持用户手动直接修改，即便强制调用状态更新接口修改，也会被APIServer校验拒绝或者被kubelet后续的状态同步覆盖。
2. 你原代码中调用的是通用Update()方法，该方法默认仅处理Pod spec字段的变更，你修改的status字段内容会被APIServer直接忽略，所以无报错但也不会生效。

可行实现方案 #

你的需求是让运行中的Pod停止运行，Phase变为Completed状态且保留Pod对象，可按以下方案实现：
首先确认目标Pod的重启策略为Never或OnFailure（Argo Workflows创建的Pod默认满足该要求），只有这两种重启策略下，容器退出后Pod不会被重启，会保留Completed状态。

方案1：原生优雅终止（推荐） #

调用Pod删除接口并配置优雅终止参数，kubelet会自动给容器主进程发送SIGTERM信号，等待进程优雅退出后容器停止，Pod状态自动更新为Completed，配置孤儿删除策略即可保留Pod对象：

// 省略前面的clientset初始化逻辑
deleteGracePeriod := int64(30) // 优雅终止等待时长，单位秒
_, err = clientset.CoreV1().Pods("argo-workflows").Delete(
    context.TODO(),
    podName,
    metav1.DeleteOptions{
        GracePeriodSeconds: &deleteGracePeriod,
        PropagationPolicy:  &[]metav1.DeletionPropagation{metav1.DeletePropagationOrphan}[0],
    },
)
if err != nil {
    panic(fmt.Errorf("终止Pod失败: %v", err))
}

方案2：强制终止容器进程 #

如果不希望调用删除接口，可以通过exec接口进入容器直接发送退出信号给主进程，容器退出后Pod状态自动更新为Completed：

// 导入exec相关依赖
import (
    "k8s.io/client-go/tools/remotecommand"
    // 其他依赖省略
)

// 构造exec请求
req := clientset.CoreV1().RESTClient().Post().
    Namespace("argo-workflows").
    Name(podName).
    Resource("pods").
    SubResource("exec").
    Param("container", containerName). // 替换为实际容器名
    Param("cmd", "/bin/sh").
    Param("cmd", "-c").
    Param("cmd", "kill 1"). // 给1号主进程发终止信号
    Param("stderr", "true").
    Param("stdout", "true")

// 执行exec请求
exec, err := remotecommand.NewSPDYExecutor(config, "POST", req.URL())
if err != nil {
    panic(fmt.Errorf("构造exec请求失败: %v", err))
}

err = exec.Stream(remotecommand.StreamOptions{
    Stdout: os.Stdout,
    Stderr: os.Stderr,
})
if err != nil {
    panic(fmt.Errorf("执行exec命令失败: %v", err))
}

操作完成后等待几秒，kubelet同步状态后Pod的Phase就会自动更新为Completed（Succeeded/Failed）状态。

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