package main
<p>import (
"context"
"fmt"
"time"</p><pre class='brush:php;toolbar:false;'>appsv1 "k8s.io/api/apps/v1"
met*1 "k8s.io/apimachinery/pkg/apis/meta/v1"
"k8s.io/client-go/kubernetes"
"k8s.io/client-go/tools/clientcmd"

)

func main() { config, err := clientcmd.BuildConfigFromFlags("", "/path/to/kubeconfig") if err != nil { panic(err) }

clientset, err := kubernetes.NewForConfig(config)
if err != nil {
    panic(err)
}

// 获取目标Deployment
deployment, err := clientset.AppsV1().Deployments("default").Get(context.TODO(), "my-app", met*1.GetOptions{})
if err != nil {
    panic(err)
}

// 更新镜像版本
deployment.Spec.Template.Spec.Containers[0].Image = "my-app:v2.0"

// 设置滚动更新策略
deployment.Spec.Strategy = appsv1.DeploymentStrategy{
    Type: appsv1.RollingUpdateDeploymentStrategyType,
    RollingUpdate: &appsv1.RollingUpdateDeployment{
        MaxSurge:       func() *intstr.IntOrString { i := intstr.FromInt(1); return &i }(),
        MaxUn*ailable: func() *intstr.IntOrString { i := intstr.FromInt(0); return &i }(),
    },
}

// 提交更新
_, err = clientset.AppsV1().Deployments("default").Update(context.TODO(), deployment, met*1.UpdateOptions{})
if err != nil {
    panic(err)
}

fmt.Println("Deployment updated, waiting for rollout...")

// 等待更新完成
waitForRollout(clientset, "default", "my-app")

}

专注于健康医疗垂直领域的AI技术开放平台

func waitForRollout(clientset *kubernetes.Clientset, namespace, name string) {
    for {
        deployment, err := clientset.AppsV1().Deployments(namespace).Get(context.TODO(), name, met*1.GetOptions{})
        if err != nil {
            panic(err)
        }
<pre class='brush:php;toolbar:false;'>    // 检查可用副本是否达标
    if deployment.Status.ReadyReplicas == *deployment.Spec.Replicas {
        fmt.Println("Rollout completed successfully.")
        break
    }

    fmt.Printf("Waiting for rollout... %d/%d ready\n", deployment.Status.ReadyReplicas, *deployment.Spec.Replicas)
    time.Sleep(2 * time.Second)
}

}