大鹏一日同风起，扶摇直上九万里。这篇文章主要讲述client-go gin的简单整合十-Update相关的知识，希望能为你提供帮助。
背景完成了client-go gin的简单整合九-Create的namespace deploymentpod的 创建操作，现在进行一下update修改的操作！
update namespace 以某 ns为例增加一个标签关于namespace，我们用的最多的标签是name 和labels(恩前面我还做过配额的例子，这里就简单的拿labels为例了)

[zhangpeng@zhangpeng k8s-demo1]$ kubectl get ns --show-labels NAMESTATUSAGELABELS defaultActive53dkubernetes.io/metadata.name=default kube-node-leaseActive53dkubernetes.io/metadata.name=kube-node-lease kube-publicActive53dkubernetes.io/metadata.name=kube-public kube-systemActive53dkubernetes.io/metadata.name=kube-system zhangpengActive1skubernetes.io/metadata.name=zhangpeng zhangpeng1Active3h21mkubernetes.io/metadata.name=zhangpeng1

如果去update修改namespace我们常用的应该是修改namespace的labels，以zhangpeng namespace为例，我想增加一个name=abcd的标签
/src/service/Namespace.go

package serviceimport ( "context" "fmt" "github.com/gin-gonic/gin" . "k8s-demo1/src/lib" v1 "k8s.io/api/core/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "time" )type Time struct time.Time `protobuf:"-"`type Namespace struct Namestring`json:"name"` CreateTimetime.Time`json:"CreateTime"` Statusstring`json:"status"` Labelsmap[string]string `json:"labels"` Annotations map[string]string `json:"annotations"`func ListNamespace(g *gin.Context) ns, err := K8sClient.CoreV1().Namespaces().List(context.Background(), metav1.ListOptions) if err != nil g.Error(err) returnret := make([]*Namespace, 0) for _, item := range ns.Items ret = append(ret, & Namespace Name:item.Name, CreateTime: item.CreationTimestamp.Time, Status:string(item.Status.Phase), Labels:item.Labels, )g.JSON(200, ret) returnfunc create(ns Namespace) (*v1.Namespace, error) ctx := context.Background() newNamespace, err := K8sClient.CoreV1().Namespaces().Create(ctx, & v1.Namespace ObjectMeta: metav1.ObjectMeta Name:ns.Name, Labels: ns.Labels, , , metav1.CreateOptions) if err != nil fmt.Println(err)return newNamespace, errfunc updatenamespace(ns Namespace) (*v1.Namespace, error) ctx := context.Background() newNamespace, err := K8sClient.CoreV1().Namespaces().Update(ctx, & v1.Namespace ObjectMeta: metav1.ObjectMeta Name:ns.Name, Labels: ns.Labels, , , metav1.UpdateOptions) if err != nil fmt.Println(err)return newNamespace, errfunc CreateNameSpace(g *gin.Context) var nameSpace Namespace if err := g.ShouldBind(& nameSpace); err != nil g.JSON(500, err)namespace, err := create(nameSpace) if err != nil g.JSON(500, err)ns := Namespace Name:namespace.Name, CreateTime:namespace.CreationTimestamp.Time, Status:string(namespace.Status.Phase), Labels:nil, Annotations: nil,g.JSON(200, ns)func UpdateNameSpace(g *gin.Context) var nameSpace Namespace if err := g.ShouldBind(& nameSpace); err != nil g.JSON(500, err)namespace, err := updatenamespace(nameSpace) if err != nil g.JSON(500, err)ns := Namespace Name:namespace.Name, CreateTime:namespace.CreationTimestamp.Time, Status:string(namespace.Status.Phase), Labels:namespace.Labels, Annotations: nil,g.JSON(200, ns)

创建updatenamespace方法UpdateNameSpace service
main.go创建路由：

package mainimport ( "github.com/gin-gonic/gin" "k8s-demo1/src/core" "k8s-demo1/src/service" //"k8s.io/client-go/informers/core" )func main() r := gin.Default() r.GET("/", func(context *gin.Context) context.JSON(200, "hello") ) r.GET("/namespaces", service.ListNamespace) r.POST("/namespace", service.CreateNameSpace) r.POST("/namespace/update", service.UpdateNameSpace) r.GET("/deployments", service.ListDeployment) r.GET("/service", service.ListService) r.GET("pods", service.ListallPod) r.POST("/pod", service.CreatePod) r.POST("/deployment", service.CreateDep) core.InitDeployment() r.Run()

运行main.go
Postman 测试post http://127.0.0.1:8080/namespace/update

"name":"zhangpeng", "labels":"name":"abcd"

文章图片

[zhangpeng@zhangpeng k8s-demo1]$ kubectl get ns --show-labels

文章图片

修改name标签为其他值post http://127.0.0.1:8080/namespace/update

"name":"zhangpeng", "labels":"name":"abcd123"

文章图片

其他的可以玩的：扩展一下resourcequotas，可以参照这个的搞一下quota的配置，这里就不先演示了呢！
update pod? pod是否可以update更新呢？pod是否可以update更新呢？答案是否定的......
注：pod是一个容器的生命周期，理论上是不可以更新的，而且一般的pod 是基于基于deployment or rs等控制管理pod的，修改则意为着生命周期的结束和新的pod的产生，当然了可以基于openkruise的其他的应用实现pod的原地升级！
依着葫芦画瓢，体验一下错误

[zhangpeng@zhangpeng k8s]$ kubectl get pods -n zhangpeng NAMEREADYSTATUSRESTARTSAGE zhangpeng1/1Running078m

[zhangpeng@zhangpeng k8s-demo1]$ kubectl get pods -o yaml -n zhangpeng apiVersion: v1 items: - apiVersion: v1 kind: Pod metadata: creationTimestamp: "2022-06-22T02:31:49Z" name: zhangpeng namespace: zhangpeng resourceVersion: "6076576" uid: cee39c9d-fc29-40ee-933e-d9fa76ba20e1 spec: containers: - image: nginx imagePullPolicy: Always name: zhangpeng resources: terminationMessagePath: /dev/termination-log terminationMessagePolicy: File volumeMounts: - mountPath: /var/run/secrets/kubernetes.io/serviceaccount name: kube-api-access-f7qvv readOnly: true dnsPolicy: ClusterFirst enableServiceLinks: true nodeName: k8s-2 preemptionPolicy: PreemptLowerPriority priority: 0 restartPolicy: Always schedulerName: default-scheduler securityContext: serviceAccount: default serviceAccountName: default terminationGracePeriodSeconds: 30 tolerations: - effect: NoExecute key: node.kubernetes.io/not-ready operator: Exists tolerationSeconds: 300 - effect: NoExecute key: node.kubernetes.io/unreachable operator: Exists tolerationSeconds: 300 volumes: - name: kube-api-access-f7qvv projected: defaultMode: 420 sources: - serviceAccountToken: expirationSeconds: 3607 path: token - configMap: items: - key: ca.crt path: ca.crt name: kube-root-ca.crt - downwardAPI: items: - fieldRef: apiVersion: v1 fieldPath: metadata.namespace path: namespace status: conditions: - lastProbeTime: null lastTransitionTime: "2022-06-22T02:31:49Z" status: "True" type: Initialized - lastProbeTime: null lastTransitionTime: "2022-06-22T02:32:06Z" status: "True" type: Ready - lastProbeTime: null lastTransitionTime: "2022-06-22T02:32:06Z" status: "True" type: ContainersReady - lastProbeTime: null lastTransitionTime: "2022-06-22T02:31:49Z" status: "True" type: PodScheduled containerStatuses: - containerID: docker://47d2c805f72cd023ff9b33d46f63b1b8e7600f64783685fe4c16d97f4b58b290 image: nginx:latest imageID: docker-pullable://nginx@sha256:0d17b565c37bcbd895e9d92315a05c1c3c9a29f762b011a10c54a66cd53c9b31 lastState: name: zhangpeng ready: true restartCount: 0 started: true state: running: startedAt: "2022-06-22T02:32:05Z" hostIP: 192.168.0.176 phase: Running podIP: 10.244.1.64 podIPs: - ip: 10.244.1.64 qosClass: BestEffort startTime: "2022-06-22T02:31:49Z" kind: List metadata: resourceVersion: ""

/src/service/Pod.go
注：模仿deployment create写的......反正结果都是失败的，就走一遍流程看一下！后面都是要删掉的......

func (d *Pod) GetImageName() string // 全部为应为字母数字和: pods := strings.Index(d.Images, ":") if pods > 0 return d.Images[:pods]return d.Imagesfunc updatepod(pod Pod) (*corev1.Pod, error) newpod, err := K8sClient.CoreV1().Pods(pod.Namespace).Update(context.TODO(), & corev1.Pod ObjectMeta: metav1.ObjectMeta Name:pod.Name, Namespace:pod.Namespace, Labels:pod.Labels, Annotations: pod.Annotations, , Spec: corev1.PodSpec Containers: []corev1.Container Name: pod.Name, Image: pod.Images, Ports: pod.GetPorts(), , , , metav1.UpdateOptions) if err != nil fmt.Println(err)return newpod, errfunc UpdatePod(g *gin.Context) var NewPod Pod if err := g.ShouldBind(& NewPod); err != nil g.JSON(500, err)pod, err := updatepod(NewPod) if err != nil g.JSON(500, err)newpod := Pod Namespace:pod.Namespace, Name:pod.Name, Images:pod.Spec.Containers[0].Image, CreateTime:pod.CreationTimestamp.Format("2006-01-02 15:04:05"), Annotations: pod.ObjectMeta.Annotations,g.JSON(200, newpod)

main.go增加如下配置：

r.POST("/pod/update", service.UpdatePod)

运行main.go postman测试：

文章图片

恩 大概就是这个样子 就为了演示一下，更深入理解一下pod生命周期，当然了也可以去研究一下那些原地升级的方法openkruise还是很不错的！
update deployment 初始deployment为下

[zhangpeng@zhangpeng k8s]$ kubectl get pods -n zhangpeng NAMEREADYSTATUSRESTARTSAGE zhangpeng-5dffd5664f-nvfsm1/1Running027s [zhangpeng@zhangpeng k8s]$ kubectl get deployment zhangpeng -n zhangpeng NAMEREADYUP-TO-DATEAVAILABLEAGE zhangpeng1/11140s

[zhangpeng@zhangpeng k8s]$ kubectl get deployment zhangpeng -n zhangpeng -o yaml apiVersion: apps/v1 kind: Deployment metadata: annotations: deployment.kubernetes.io/revision: "1" creationTimestamp: "2022-06-22T06:44:06Z" generation: 1 name: zhangpeng namespace: zhangpeng resourceVersion: "6096527" uid: d42d5851-2e63-439b-b2a5-976b5fe246bb spec: progressDeadlineSeconds: 600 replicas: 1 revisionHistoryLimit: 10 selector: matchLabels: app: zhangpeng strategy: rollingUpdate: maxSurge: 25% maxUnavailable: 25% type: RollingUpdate template: metadata: creationTimestamp: null labels: app: zhangpeng name: zhangpeng spec: containers: - image: nginx imagePullPolicy: Always name: nginx ports: - containerPort: 80 name: web protocol: TCP resources: terminationMessagePath: /dev/termination-log terminationMessagePolicy: File dnsPolicy: ClusterFirst restartPolicy: Always schedulerName: default-scheduler securityContext: terminationGracePeriodSeconds: 30 status: availableReplicas: 1 conditions: - lastTransitionTime: "2022-06-22T06:44:24Z" lastUpdateTime: "2022-06-22T06:44:24Z" message: Deployment has minimum availability. reason: MinimumReplicasAvailable status: "True" type: Available - lastTransitionTime: "2022-06-22T06:44:06Z" lastUpdateTime: "2022-06-22T06:44:24Z" message: ReplicaSet "zhangpeng-5dffd5664f" has successfully progressed. reason: NewReplicaSetAvailable status: "True" type: Progressing observedGeneration: 1 readyReplicas: 1 replicas: 1 updatedReplicas: 1

关键词就是：

"name":"zhangpeng", "namespace":"zhangpeng", "replicas":1, "ports":"tcp,80,web", "images":"nginx"

编写程序文件/src/service/Deployment.go

func Updatedep(dep Deployment) (*v1.Deployment, error) deployment := & v1.Deployment ObjectMeta: metav1.ObjectMeta Name:dep.Name, Namespace: dep.Namespace, Labels:dep.GetLabels(), , Spec: v1.DeploymentSpec Replicas: & dep.Replicas, Selector: & metav1.LabelSelector MatchLabels: dep.GetSelectors(), , Template: corev1.PodTemplateSpec ObjectMeta: metav1.ObjectMeta Name:dep.Name, Labels: dep.GetSelectors(), , Spec: corev1.PodSpec Containers: []corev1.ContainerName:dep.GetImageName(), Image: dep.Images, Ports: dep.GetPorts(), , , , , ,ctx := context.Background() newdep, err := lib.K8sClient.AppsV1().Deployments(dep.Namespace).Update(ctx, deployment, metav1.UpdateOptions) if err != nil fmt.Println(err)return newdep, nilfunc UpdateDep(g *gin.Context) var newDep Deployment if err := g.ShouldBind(& newDep); err != nil g.JSON(500, err)newdep, err := Updatedep(newDep) if err != nil g.JSON(500, err)newDep1 := Deployment Namespace:newdep.Namespace, Name:newdep.Name, Pods:GetPodsByDep(*newdep), CreateTime: newdep.CreationTimestamp.Format("2006-01-02 15:03:04"),g.JSON(200, newDep1)

注意：基本就是拿前面的deployment create的方法改的......
增加路由运行main.gomain.go增加路由并运行main.go

r.POST("/deployment/update", service.UpdateDep)

文章图片

Postman测试 修改副本为2
http://127.0.0.1:8080/deployment/update

"name":"zhangpeng", "namespace":"zhangpeng", "replicas":2, "ports":"tcp,80,web", "images":"nginx"

文章图片

修改镜像tag
开始想的是修改nginx为nginx:1.18结果失败了......

文章图片

估计是images数据格式的问题，先忽略吧......退而求其次修改镜像为apache镜像（注意镜像是httpd）
http://127.0.0.1:8080/deployment/update

"name":"zhangpeng", "namespace":"zhangpeng", "replicas":2, "ports":"tcp,80,web", "images":"httpd"

文章图片

登陆服务器验证：

zhangpeng@zhangpeng k8s]$ kubectl get pods -n zhangpeng NAMEREADYSTATUSRESTARTSAGE zhangpeng-5546976d9-mkslb1/1Running073s zhangpeng-5546976d9-tcsb50/1ContainerCreating014s zhangpeng-5dffd5664f-nvfsm1/1Running018m [zhangpeng@zhangpeng k8s]$ kubectl get pods -n zhangpeng NAMEREADYSTATUSRESTARTSAGE zhangpeng-5546976d9-mkslb1/1Running0100s zhangpeng-5546976d9-tcsb51/1Running041s [zhangpeng@zhangpeng k8s]$ kubectl get deployment -n zhangpeng -o yaml |grep image - image: httpd imagePullPolicy: Always

总结：【client-go gin的简单整合十-Update】1.Pod生命周期
2.update与create比就修改了update metav1.UpdateOptions
3.镜像的tag标签的问题后面看一下怎么解决

推荐阅读

• 

  遇到西门子冰箱总是不制冷怎么办？3个处理方法帮助你
• 

  高血脂|高血脂人群不应该碰哪些食物？营养师：多吃这3种食物血脂水平高
• 

  古风bgm 纯音乐古风歌曲
• 

  梁汝波简介 梁汝波是谁
• 

  蟾蜍饲养方法 蟾蜍的饲养管理技术
• 

  能量和热量的区别 能量和热量的区别在哪
• 

  redis添加键值对 redis命令添加可用
• 

  lnd-al20是什么型号（lnd-al20的型号是什么）
• 

  狮子座最后一天的性格 8月22日是什么星座
• 

  东北直播视频素材，东北直播视频素材网站
• 

  爱的魔法歌词金莎 爱的魔法歌词
• 

  汽车门关不紧怎么办 汽车的门如何调整视频，汽车车门怎么拆
• 

  50mm定焦镜头拍风景 佳能用21mm定焦拍风景
• 

  黄芪怎么读 吃黄芪的好处
• 

  4P4R分析
• 

  1斤的桑葚干泡多少白酒
• 

  微信怎么发接龙消息
• 

  战神4全国度符文对照盘碎片收集图文攻略 对照盘碎片在哪 穆斯贝尔海姆符文对照盘①
• 

  金樱子是什么样子 金樱子是什么
• 

  excel的数据如何分析数据,Excel右侧数据对应左侧数据

• selenium强制等待，隐式等待，显式等待
• 测试Charles的map，rewrite，breakpoints的使用方法
• HTTPHTTP请求体中的四种格式，requests库发送post请求
• pythonprint和pprint的区别
• adbAndriod获取常用性能指标的方法
• 面试快手的客户端测试（直播）
• shell``和$()作用与区别
• 算法求一个数字在给定的已排序数组中出现的起始终止索引号
• JAVASession