首先通过client-go配置集群访问凭证，使用kubeconfig或ServiceAccount获取config并创建clientset；接着定义Deployment对象，设置副本数、选择器和Pod模板，并调用Create方法提交至API Server；更新时修改Spec并调用Update触发滚动升级；通过List方法结合LabelSelector获取关联的ReplicaSet，查看其副本状态以判断缩容情况；利用Informer监听Deployment的Add和Update事件，实现对状态变化的实时响应；最终基于控制器模式构建自动化运维工具。
在 Kubernetes 中，Deployment 和 ReplicaSet 是管理应用副本和滚动更新的核心控制器。使用 Golang 编写程序来管理这些资源，能实现自动化部署、状态监控与故障恢复。本文介绍如何通过 client-go 与 Kubernetes API 交互，完成对 Deployment 和其底层 ReplicaSet 的操作。
连接 Kubernetes 集群
使用 client-go 前需配置集群访问凭证。开发环境通常使用 kubeconfig 文件，生产环境推荐使用 Pod 内置 ServiceAccount。
clientset, err := kubernetes.NewForConfig(config) if err != nil { log.Fatal(err) }config 可通过 rest.InClusterConfig()（Pod 内运行）或 clientcmd.BuildConfigFromFlags()（本地调试）获取。
创建与更新 Deployment
定义 Deployment 对象并提交至 API Server，可声明期望的 Pod 模板与副本数。
立即学习“go语言免费学习笔记（深入）”；
deployment := &appsv1.Deployment{ ObjectMeta: metav1.ObjectMeta{ Name: "my-app", Namespace: "default", }, Spec: appsv1.DeploymentSpec{ Replicas: int32Ptr(3), Selector: &metav1.LabelSelector{ MatchLabels: map[string]string{"app": "my-app"}, }, Template: v1.PodTemplateSpec{ ObjectMeta: metav1.ObjectMeta{ Labels: map[string]string{"app": "my-app"}, }, Spec: v1.PodSpec{ Containers: []v1.Container{{ Name: "web", Image: "nginx:latest", }}, }, }, }, } _, err := clientset.AppsV1().Deployments("default").Create( context.TODO(), deployment, metav1.CreateOptions{}) if err != nil { log.Fatal(err) }更新 Deployment 时，修改其 Spec 并调用 Update 方法。Kubernetes 会自动触发滚动升级。
查看与管理 ReplicaSet
Deployment 控制器会自动生成 ReplicaSet 来管理 Pod 副本。可通过以下方式列出某 Deployment 关联的 ReplicaSet：
rsList, err := clientset.AppsV1().ReplicaSets("default").List( context.TODO(), metav1.ListOptions{ LabelSelector: "app=my-app", }) if err != nil { log.Fatal(err) } for _, rs := range rsList.Items { fmt.Printf("ReplicaSet: %s, Pods: %d\n", rs.Name, *rs.Spec.Replicas) }旧的 ReplicaSet 保留用于回滚，可通过观察其 status.replicas 判断是否已缩容为 0。
监听 Deployment 状态变化
使用 Informer 监听 Deployment 事件，实现实时响应。
informerFactory := informers.NewSharedInformerFactory(clientset, 0) deploymentInformer := informerFactory.Apps().V1().Deployments().Informer() deploymentInformer.AddEventHandler(&cache.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) { d := obj.(*appsv1.Deployment) log.Printf("Deployment added: %s", d.Name) }, UpdateFunc: func(old, new interface{}) { newD := new.(*appsv1.Deployment) log.Printf("Deployment updated: %s", newD.Name) }, }) informerFactory.Start(wait.NeverStop) informerFactory.WaitForCacheSync(wait.NeverStop)Informer 减少轮询开销，适合长期运行的控制器或监控服务。
基本上就这些。掌握 client-go 的基本用法后，可以构建更复杂的 Operator 或 CI/CD 集成工具。关键在于理解控制器模式与资源生命周期。
