ToB企服应用市场:ToB评测及商务社交产业平台

标题: client-go实战之八:更新资源时的冲突错误处理 [打印本页]
作者: 我可以不吃啊    时间: 2023-11-4 08:00
标题: client-go实战之八:更新资源时的冲突错误处理
欢迎访问我的GitHub

这里分类和汇总了欣宸的全部原创(含配套源码)：https://github.com/zq2599/blog_demos
本篇概览

什么是版本冲突（from kubernetes官方）

编码，复现版本冲突


  1. $ tree client-go-tutorials
  2. client-go-tutorials
  3. ├── action
  4. │   ├── action.go
  5. │   ├── conflict.go
  6. │   └── list_pod.go
  7. ├── client-go-tutorials
  8. ├── go.mod
  9. ├── go.sum
  10. └── main.go
复制代码
  1. const (
  2.         // deployment的名称
  3.         DP_NAME string = "demo-deployment"
  4.         // 用于更新的标签的名字
  5.         LABEL_CUSTOMIZE string = "biz-version"
  6. )
复制代码
  1. func int32Ptr(i int32) *int32 { return &i }
复制代码
  1. // 创建deployment
  2. func create(clientset *kubernetes.Clientset) error {
  3.         deploymentsClient := clientset.AppsV1().Deployments(apiv1.NamespaceDefault)
  5.         deployment := &appsv1.Deployment{
  6.                 ObjectMeta: metav1.ObjectMeta{
  7.                         Name:   DP_NAME,
  8.                         Labels: map[string]string{LABEL_CUSTOMIZE: "101"},
  9.                 },
  10.                 Spec: appsv1.DeploymentSpec{
  11.                         Replicas: int32Ptr(1),
  12.                         Selector: &metav1.LabelSelector{
  13.                                 MatchLabels: map[string]string{
  14.                                         "app": "demo",
  15.                                 },
  16.                         },
  17.                         Template: apiv1.PodTemplateSpec{
  18.                                 ObjectMeta: metav1.ObjectMeta{
  19.                                         Labels: map[string]string{
  20.                                                 "app": "demo",
  21.                                         },
  22.                                 },
  23.                                 Spec: apiv1.PodSpec{
  24.                                         Containers: []apiv1.Container{
  25.                                                 {
  26.                                                         Name:  "web",
  27.                                                         Image: "nginx:1.12",
  28.                                                         Ports: []apiv1.ContainerPort{
  29.                                                                 {
  30.                                                                         Name:          "http",
  31.                                                                         Protocol:      apiv1.ProtocolTCP,
  32.                                                                         ContainerPort: 80,
  33.                                                                 },
  34.                                                         },
  35.                                                 },
  36.                                         },
  37.                                 },
  38.                         },
  39.                 },
  40.         }
  42.         // Create Deployment
  43.         fmt.Println("Creating deployment...")
  44.         result, err := deploymentsClient.Create(context.TODO(), deployment, metav1.CreateOptions{})
  45.         if err != nil {
  46.                 return err
  47.         }
  49.         fmt.Printf("Created deployment %q.\n", result.GetObjectMeta().GetName())
  51.         return nil
  52. }
复制代码
  1. // 按照名称删除
  2. func delete(clientset *kubernetes.Clientset, name string) error {
  3.         deletePolicy := metav1.DeletePropagationBackground
  5.         err := clientset.AppsV1().Deployments(apiv1.NamespaceDefault).Delete(context.TODO(), name, metav1.DeleteOptions{PropagationPolicy: &deletePolicy})
  7.         if err != nil {
  8.                 return err
  9.         }
  11.         return nil
  12. }
复制代码
  1. // 按照名称查找deployment
  2. func get(clientset *kubernetes.Clientset, name string) (*v1.Deployment, error) {
  3.         deployment, err := clientset.AppsV1().Deployments(apiv1.NamespaceDefault).Get(context.TODO(), name, metav1.GetOptions{})
  4.         if err != nil {
  5.                 return nil, err
  6.         }
  8.         return deployment, nil
  9. }
复制代码
  1. // 查询指定名称的deployment对象，得到其名为biz-version的label，加一后保存
  2. func updateByGetAndUpdate(clientset *kubernetes.Clientset, name string) error {
  4.         deployment, err := clientset.AppsV1().Deployments(apiv1.NamespaceDefault).Get(context.TODO(), name, metav1.GetOptions{})
  6.         if err != nil {
  7.                 return err
  8.         }
  10.         // 取出当前值
  11.         currentVal, ok := deployment.Labels[LABEL_CUSTOMIZE]
  13.         if !ok {
  14.                 return errors.New("未取得自定义标签")
  15.         }
  17.         // 将字符串类型转为int型
  18.         val, err := strconv.Atoi(currentVal)
  20.         if err != nil {
  21.                 fmt.Println("取得了无效的标签，重新赋初值")
  22.                 currentVal = "101"
  23.         }
  25.         // 将int型的label加一，再转为字符串
  26.         deployment.Labels[LABEL_CUSTOMIZE] = strconv.Itoa(val + 1)
  28.         _, err = clientset.AppsV1().Deployments(apiv1.NamespaceDefault).Update(context.TODO(), deployment, metav1.UpdateOptions{})
  29.         return err
  30. }
复制代码
[code]type Confilct struct{}func (conflict Confilct) DoAction(clientset *kubernetes.Clientset) error {        fmt.Println("开始创建deployment")        // 开始创建deployment        err := create(clientset)        if err != nil {                return err        }        // 如果不延时，就会导致下面的更新过早，会报错



欢迎光临 ToB企服应用市场:ToB评测及商务社交产业平台 (https://dis.qidao123.com/) Powered by Discuz! X3.4