您的位置:首页 > 娱乐 > 八卦 > [k8s源码]2.CURD deployment

[k8s源码]2.CURD deployment

2025/6/29 21:10:30 来源:https://blog.csdn.net/weixin_45396500/article/details/140414957  浏览:    关键词:[k8s源码]2.CURD deployment
加载kubernetes配置

使用 clientcmd方法,是通过"k8s.io/client-go/tools/clientcmd"包加载的。这个函数返回的是config和error两个值。可以看到返回的config是一个指针变量。

func clientcmd.BuildConfigFromFlags(masterUrl string, kubeconfigPath string) (*rest.Config, error)

config,err := clientcmd.BuildConfigFromFlags("", "C:/Users/gx/.kube/config")
if err != nil {panic(err.Error())}
创建kubernetes客户端

func kubernetes.NewForConfig(c *rest.Config) (*kubernetes.Clientset, error)

这里的err被重新赋值,而传入的config是一个指针变量。

deployment 是一个appsv1变量,因此使用appsv1 方法来获取用于与 Kubernetes AppsV1 API 交互的客户端。这样可以轻松地对 Kubernetes 中的 Apps 资源(如 Deployment、StatefulSet 等)进行操作。

clientset, err := clientset.NewForConfig(config) 
if err != nil {panic(err.Error())
}
deploymentClientset := clientset.AppsV1().Deployments(apiv1.NamespaceDefault)
编写要创建的deployment 

指针允许不同的结构体实例共享相同的数据。在Kubernetes中,多个Pod可能需要共享相同的标签选择器配置。通过指针可以实现这一点。所以这里的deployment和LabelSelector是指针。这里的container和port是切片类型的数据。

deployment := &appsv1.Deployment{ObjectMeta: metav1.ObjectMeta{Name: "demo-deployment",},Spec: appsv1:DeploymentSpec{Replicas: 3,Selector: &metav1.LabelSelector{MatchLabels: map[string]string{"app": "demo",}},},Template: apiv1.PodTemplateSpec{ObjectMeta: metav1.ObjectMeta{Labels: map[string]string{"app":"demo",}},},spec: apiv1.PodSpec{Containers:[]apiv1.Container{{Name: "web",Image: "nginx:1.12",Ports: []apiv1.ContainerPort{{Name: "http",Protocol: apiv1.ProtocolTCP,ContainerPort: 80,}},},},},},},
}

另一种编写方式,更加简洁,但是可能存在安全性和规范性的问题

deployment := &unstructured.Unstructured{Object: map[string]interface{}{"apiVersion": "apps/v1","kind":       "Deployment","metadata": map[string]interface{}{"name": "demo-deployment",},"spec": map[string]interface{}{"replicas": 2,"selector": map[string]interface{}{"matchLabels": map[string]interface{}{"app": "demo",},},"template": map[string]interface{}{"metadata": map[string]interface{}{"labels": map[string]interface{}{"app": "demo",},},"spec": map[string]interface{}{"containers": []map[string]interface{}{{"name":  "web","image": "nginx:1.12","ports": []map[string]interface{}{{"name":          "http","protocol":      "TCP","containerPort": 80,},},},},},},},},
}
 创建deployment

func (v1.DeploymentInterface) Create(ctx context.Context, deployment *appsv1.Deployment, opts metav1.CreateOptions) (*appsv1.Deployment, error)

在 Go 语言中,context.TODO() 是 context 包中的一个函数调用,它返回一个空的 Context 对象。Context 在 Go 中用于控制并发时的取消操作、超时控制、截止时间等,可以有效地管理并传递请求范围的值。context.TODO() 表示一个“空”的 Context,通常用作临时占位符或者当你尚未确定使用哪种具体的 Context 类型时的默认选择。

metav1.CreateOptions{} 是用于在创建资源时传递额外选项的结构体。可以通过metav1.CreateOptions{} 提供一些创建过程中需要的配置信息,例如:

  1. DryRun: 设置为 true 可以模拟创建操作,而不会实际创建资源。
  2. FieldManager: 设置创建资源的管理者的名称,用于标识谁在进行这次创建操作。
  3. Labels: 设置资源的标签,用于对资源进行分类和组织。
  4. PropagationPolicy: 设置删除资源时的传播策略,影响关联资源的删除行为。
createOptions := metav1.CreateOptions{DryRun:       []string{"All"}, // 模拟创建,不实际创建资源FieldManager: "my-controller", // 设置创建资源的管理者Labels: map[string]string{"app": "demo",},// 可以根据需要添加其他选项
}deploymentsClient.Create(context.TODO(), deployment, createOptions)

具体在我们的代码里面,用以下命令创建deployment

result, err := deploymentsClient.Create(context.TODO(), deployment, metav1.CreateOptions{})if err != nil {panic(err)}fmt.Printf("Created deployment %q.\n", result.GetObjectMeta().GetName())
更新deployment

retry.RetryOnConflict 函数是一个用于处理在更新资源时可能遇到的冲突的函数。在更新资源时,可能会因为多个并发请求同时修改资源而产生冲突。RetryOnConflict 函数会帮助你处理这种情况,使用指数退避策略(exponential backoff)来避免频繁地向 API 服务器发送请求,从而减少对 API 服务器的负载和提高更新成功的几率。

func retry.RetryOnConflict(backoff wait.Backoff, fn func() error) error

func (v1.DeploymentInterface) Update(ctx context.Context, deployment *appsv1.Deployment, opts metav1.UpdateOptions) (*appsv1.Deployment, error)

retry这个函数来源于包:"k8s.io/client-go/util/retry"

retryErr := retry.RetryOnConflict(retry.DefaultRetry, func() error {// Retrieve the latest version of Deployment before attempting update// RetryOnConflict uses exponential backoff to avoid exhausting the apiserverresult, getErr := deploymentsClient.Get(context.TODO(), "demo-deployment", metav1.GetOptions{})if getErr != nil {panic(fmt.Errorf("Failed to get latest version of Deployment: %v", getErr))}result.Spec.Replicas = int32Ptr(1)                           // reduce replica countresult.Spec.Template.Spec.Containers[0].Image = "nginx:1.13" // change nginx version_, updateErr := deploymentsClient.Update(context.TODO(), result, metav1.UpdateOptions{})return updateErr})if retryErr != nil {panic(fmt.Errorf("Update failed: %v", retryErr))}fmt.Println("Updated deployment...")
 列举deployments
fmt.Printf("Listing deployments in namespace %q:\n", apiv1.NamespaceDefault)list, err := deploymentsClient.List(context.TODO(), metav1.ListOptions{})if err != nil {panic(err)}for _, d := range list.Items {fmt.Printf(" * %s (%d replicas)\n", d.Name, *d.Spec.Replicas)}
删除deployment
deletePolicy := metav1.DeletePropagationForegroundif err := deploymentsClient.Delete(context.TODO(), "demo-deployment", metav1.DeleteOptions{PropagationPolicy: &deletePolicy,}); err != nil {panic(err)}fmt.Println("Deleted deployment.")
}

版权声明:

本网仅为发布的内容提供存储空间,不对发表、转载的内容提供任何形式的保证。凡本网注明“来源:XXX网络”的作品,均转载自其它媒体,著作权归作者所有,商业转载请联系作者获得授权,非商业转载请注明出处。

我们尊重并感谢每一位作者,均已注明文章来源和作者。如因作品内容、版权或其它问题,请及时与我们联系,联系邮箱:809451989@qq.com,投稿邮箱:809451989@qq.com