栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Go语言

[golang]-clieng-go更新deployment的各个参数配置

Go语言 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

[golang]-clieng-go更新deployment的各个参数配置

导语:更新deployment的各个参数配置

仅修改replicas个数为1

package main

import (
	"context"
	"fmt"
	"log"

	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
	"k8s.io/client-go/kubernetes"
	"k8s.io/client-go/tools/clientcmd"
)

func main() {
	configPath := "./config"
	config, err := clientcmd.BuildConfigFromFlags("", configPath)
	if err != nil {
		log.Fatal(err)
	}
	clientset, err := kubernetes.NewForConfig(config)
	if err != nil {
		panic(err)
	}

	namespace := "default"

	name := "nginx"
	// 获取名为nginx的deployment信息
	deploymentList, err := clientset.AppsV1().Deployments(namespace).Get(context.TODO(), name, metav1.GetOptions{})
	fmt.Println(err, deploymentList)

	var replicas int32 = 1
	deploymentList.Spec.Replicas = &replicas
	newdeploymentList, err := clientset.AppsV1().Deployments(namespace).Update(context.TODO(), deploymentList, metav1.UpdateOptions{})
	fmt.Println(err, newdeploymentList)

}

go run editDeploy.go

package main

import (
	"context"
	"fmt"
	"log"

	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
	"k8s.io/client-go/kubernetes"
	"k8s.io/client-go/tools/clientcmd"
)

func main() {
	configPath := "./config"
	config, err := clientcmd.BuildConfigFromFlags("", configPath)
	if err != nil {
		log.Fatal(err)
	}
	clientset, err := kubernetes.NewForConfig(config)
	if err != nil {
		panic(err)
	}

	namespace := "default"

	name := "nginx"
	// 获取名为nginx的deployment信息
	deploymentList, err := clientset.AppsV1().Deployments(namespace).Get(context.TODO(), name, metav1.GetOptions{})
	fmt.Println(err, deploymentList)

	// 设置replicas的个数
	var replicas int32 = 1
	deploymentList.Spec.Replicas = &replicas
	// 设置container 0的镜像 这里要注意只更新了一个容器的镜像
	deploymentList.Spec.Template.Spec.Containers[0].Image = "nginx:1.20.2"
	newdeploymentList, err := clientset.AppsV1().Deployments(namespace).Update(context.TODO(), deploymentList, metav1.UpdateOptions{})
	fmt.Println(err, newdeploymentList)

}

通过scale进行replicas的扩容

package main

import (
	"context"
	"fmt"
	"log"

	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
	"k8s.io/client-go/kubernetes"
	"k8s.io/client-go/tools/clientcmd"
)

func main() {
	configPath := "./config"
	config, err := clientcmd.BuildConfigFromFlags("", configPath)
	if err != nil {
		log.Fatal(err)
	}
	clientset, err := kubernetes.NewForConfig(config)
	if err != nil {
		panic(err)
	}

	namespace := "default"

	name := "nginx"
	// 获取名为nginx的deployment信息
	deploymentList, err := clientset.AppsV1().Deployments(namespace).Get(context.TODO(), name, metav1.GetOptions{})
	fmt.Println(err, deploymentList)

	scale, err := clientset.AppsV1().Deployments(namespace).GetScale(context.TODO(), name, metav1.GetOptions{})
	scale.Spec.Replicas = 2
	fmt.Println(err, scale)

	newslale, err := clientset.AppsV1().Deployments(namespace).UpdateScale(context.TODO(), name, scale, metav1.UpdateOptions{})
	fmt.Println(err, newslale)

}

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/903967.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号