在client-go中删除作业并等待作业被删除

import (
    "context"
    "fmt"
    "time"

    "k8s.io/apimachinery/pkg/api/errors"
    metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
    "k8s.io/client-go/kubernetes"
    "k8s.io/client-go/tools/clientcmd"
)

func main() {
    // 创建Kubernetes客户端
    config, err := clientcmd.BuildConfigFromFlags("", "path/to/kubeconfig")
    if err != nil {
        panic(err)
    }
    clientset, err := kubernetes.NewForConfig(config)
    if err != nil {
        panic(err)
    }

    // 获取作业对象
    jobName := "example-job"
    namespace := "default"
    job, err := clientset.BatchV1().Jobs(namespace).Get(context.TODO(), jobName, metav1.GetOptions{})
    if err != nil {
        if errors.IsNotFound(err) {
            fmt.Printf("作业 %s 不存在\n", jobName)
        } else {
            panic(err)
        }
    }

    // 删除作业
    err = clientset.BatchV1().Jobs(namespace).Delete(context.TODO(), jobName, metav1.DeleteOptions{})
    if err != nil {
        panic(err)
    }

    // 等待作业被删除
    for {
        _, err := clientset.BatchV1().Jobs(namespace).Get(context.TODO(), jobName, metav1.GetOptions{})
        if err != nil {
            if errors.IsNotFound(err) {
                fmt.Printf("作业 %s 已被删除\n", jobName)
                break
            } else {
                panic(err)
            }
        }
        time.Sleep(5 * time.Second)
    }
}