k8sailor - 03 连接 k3s 集群获取 deployment 信息
2023-02-18 16:39:38 时间
tag: https://github.com/tangx/k8sailor/tree/feat/02-connect-cluster
使用 sdk 链接 k3s cluster 并获取 deployment 信息
cd cmd/k8sailor && go run .
* my-nginx-1 (1 replicas)
* my-nginx-2 (2 replicas)
下载 client-go sdk
之前在安装 k3s 集群的时候,版本是 v0.21.4。因此。这里选择 client-go sdk 的版本也是 v0.21.4
如果还有其他环境, 可以使用 go mod edit
命令锁定 client-go 的版本
go get k8s.io/client-go@v0.21.4
go mod edit -replace=k8s.io/client-go=k8s.io/client-go@v0.21.4
连接集群并获取 deployment
https://github.com/kubernetes/client-go/blob/master/examples/create-update-delete-deployment/main.go
连接到 cluster 的鉴权方式有多种, 后面可以根据 cobra 传递的参数值, 选择不同的鉴权方式。这里直接参考官方 demo 使用配置文件方式鉴权。
修改一下 kubeconfig 配置来源地址。
pkg/k8s/cluster.go
// 从 cobra 配置中获取地址
kubeconfig := &global.Flags.Config
// 其他一样
config, err := clientcmd.BuildConfigFromFlags("", *kubeconfig)
if err != nil {
panic(err)
}
clientset, err := kubernetes.NewForConfig(config)
if err != nil {
panic(err)
}
/* clientset 测试开始, 打印 default namespace 下的所有 deployment */
depClient := clientset.AppsV1().Deployments(apiv1.NamespaceDefault)
list, err := depClient.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)
}
/* clienset 测试结束 */
运行
在 cmd/root.go
中调用 k8s cluster 的连接函数
var rootCmd = &cobra.Command{
// .. 省略
Run: func(cmd *cobra.Command, args []string) {
// 连接 k3s
k8s.Connent()
},
}
运行结果如开篇所示。
相关文章
- java中的NIO和IO到底是什么区别?20个问题告诉你答案
- 数据结构001:最大子数组和
- 数据结构002:买卖股票的最佳时机
- 怎样优化Vue项目
- 数据结构003:有效的数独
- 家电行业的数字化升级:电子采购平台系统如何助力企业降本增效,提升采购协同效率?
- 六西格玛工具:柏拉图
- 友元类和嵌套类
- RTTI和类型转换运算符
- YAML快速入门
- 提升汽配供应链效率,S2B2C电商系统实现企业库存管理智能化
- 虚拟现实 VR 碰撞 3D 可视化,图扑打造一体化管控平台
- 一篇文章教你实战Docker容器数据卷
- 一起从零到一手写迷你版Vue
- 一起实现React-Hooks核心原理
- 内部群炸锅了,同事又删库了
- 一女程序员因薪酬问题离职,rm -f * 删库,瘫痪6个小时,被判9个月
- 广域铭岛参编《数智化供应链参考架构》标准正式发布
- 每周 Postgres 世界动态 2022w49
- 公司架构师常常提起的DNS负载均衡是个什么鬼?