[k8s源码]1.client-go集群外部署

client-go是由k8s发布且维护的专门用于开发者和kubernetes交互的客户端库。它支持对k8s资源的CRUD操作(create、read、update、delete),事件监听和处理,访问kubernetes集群的上下文和配置。

client go是独立于kubernetes集群之外,但是又和集群交互的客户端机器。在这台机器上安装go环境以及和kubernetes建立连接。

Linux 

安装go环境

在新的节点(在我这里是虚拟机)上安装go环境,首先下载go的安装包,在官网下载。All releases - The Go Programming Language

由于我安装的是server版的虚拟机,所以安装go环境的时候,使用curl命令来下载安装包。因为要确定go环境与k8s集群的兼容性,所以要查看集群的k8s版本。

[root@master ~]# kubectl version --short
Client Version: v1.23.1
Server Version: v1.23.1

查看kubernetes官方文档发现是与go的1.19.5版本相匹配

[root@client ~]# curl -L -O https://go.dev/dl/go1.19.5.linux-amd64.tar.gz% Total    % Received % Xferd  Average Speed   Time    Time     Time  CurrentDload  Upload   Total   Spent    Left  Speed
100    75  100    75    0     0    131      0 --:--:-- --:--:-- --:--:--   131
100 65.7M  100 65.7M    0     0  3446k      0  0:00:19  0:00:19 --:--:-- 3513k
[root@client ~]# file go1.22.5.linux-amd64.tar.gz
# 验证下载文件的类型是否为压缩包
go1.22.5.linux-amd64.tar.gz: gzip compressed data, max compression, original size modulo 2^32 232839680 gzip compressed data, unknown method, has CRC, extra field, has comment, encrypted, from FAT filesystem (MS-DOS, OS/2, NT), original size modulo 2^32 232839680
[root@client ~]# rm -rf /usr/local/go && tar -C /usr/local -xzf go1.22.5.linux-amd64.tar.gz

将go加入环境变量,并查看go的版本,以确定go是否安装成功。

[root@client ~]# export PATH=$PATH:/usr/local/go/bin
[root@client ~]# go version
go version go1.19.5 linux/amd64

将go持久化的加入环境变量,将上面的export PATH=...写入系统文件。

[root@client ~]# vim ~/.bashrc
[root@client ~]# source ~/.bashrc
配置client-go

如果您使用的 Kubernetes 版本 >= v1.17.0,请使用相应的 v0.x.y 标签。例如,k8s.io/client-go@v0.20.4 对应于 Kubernetes v1.20.4。我的版本为1.23.1,所以下载相应的client-go版本:

go get k8s.io/client-go@v0.23.1

go mod文件创建并启动go模式支持:

go mod init <module-name>
export GO111MODULE=on

 随后会创建一个初始的go.mod文件,包含模块名称和go的版本信息等,随着项目部署或者添加依赖项,go会自动更新,go.mod文件会自动更新,记录所有依赖及其版本,同时生成go.sum文件,以确保依赖项的一致性和完整性。因此go.mod文件会逐渐积累项目所需的所有依赖以及版本信息。

利用client-go抓取信息

编写main.go文件

package mainimport ("flag""fmt"metav1 "k8s.io/apimachinery/pkg/apis/meta/v1""k8s.io/client-go/kubernetes""k8s.io/client-go/tools/clientcmd""context"
)func main() {// 配置 k8s 集群外 kubeconfig 配置文件var kubeconfig *stringkubeconfig = flag.String("kubeconfig", "/etc/k8scoonfig/config", "absolute path to the kubeconfig file")namespace := flag.String("namespace","default","the namespace to list the pod from")flag.Parse()// use the current context in kubeconfigconfig, err := clientcmd.BuildConfigFromFlags("", *kubeconfig)if err != nil {panic(err.Error())}// create the clientsetclientset, err := kubernetes.NewForConfig(config)if err != nil {panic(err.Error())}// 获取集群中所有 Pod 列表pods, err := clientset.CoreV1().Pods("").List(context.TODO(), metav1.ListOptions{})if err != nil {panic(err.Error())}fmt.Printf("There are %d pods in the k8s cluster\n", len(pods.Items))// 获取指定 namespace 中的 Pod 列表pods, err = clientset.CoreV1().Pods(*namespace).List(context.TODO(), metav1.ListOptions{})if err != nil {panic(err)}fmt.Printf("There are %d pods in namespace %s\n", len(pods.Items), namespace)for _, pod := range pods.Items {fmt.Printf("Name: %s, Status: %s, CreateTime: %v\n", pod.Name, pod.Status.Phase, pod.CreationTimestamp)}
}

当指定namespace为monitor-sa,可以看到client-go成功抓取了集群中该namespace的pod数量。 

[root@client client_go_examples]# ./app -kubeconfig=/etc/k8scoonfig/config -namespace="monitor-sa"
There are 18 pods in the k8s cluster
There are 3 pods in namespace monitor-sa
Name: node-exporter-jb9jp, Status: Running, CreateTime: 2024-07-06 11:47:33 +0000 UTC
Name: node-exporter-kpvxd, Status: Running, CreateTime: 2024-07-06 11:47:33 +0000 UTC
Name: node-exporter-pwdw4, Status: Running, CreateTime: 2024-07-06 11:47:33 +0000 UTC

windows

下载kubectl。注意这里下载保存的地方就是后面要引用的地方,所以最好记住保存路径,且不要保存在下载文件夹。https://storage.googleapis.com/kubernetes-release/release/v1.18.0/bin/windows/amd64/kubectl.exe

然后把他加入环境变量,这里的kube是存储kubectl.exe的文件夹。

打开windows命令行,测试kubectl是否正常工作。 

配置kube-config,将复制到linux系统的config文件也同样复制到windows,我这里的目录是C:/user/.kube/config。随后配置到vscode中。

VSCode 

下载client-go到本地,然后在vscode中下载go的插件,以及code runner插件:

然后cstrl+shift+p,进入vscode的搜索行,安装go的插件依赖。搜索Go:install/update tools

如果出现这种情况,则需要设环境变量。设置如下四个环境变量,其中go_path是你要运行的go代码的存放目录,而go_root是你下载go存放的目录。

 查看path,如果有以下这项则为正常:

此时再尝试下载GO:install/update tools,则成功。

安装成功后,在gopath目录下安装client-go

go get k8s.io/client-go@v0.23.1
go get k8s.io/apimachinery@v0.23.1
#使用 go mod tidy 确保所有依赖项已被正确下载并添加到项目中:
go mod tidy
go run main.go

发现运行成功:

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/870636.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

Rust vs Go: 特点与应用场景分析

目录 介绍Rust的特点Go的特点Rust的应用场景Go的应用场景总结 介绍 Rust和Go&#xff08;Golang&#xff09;是现代编程语言中两个非常流行的选择。凭借各自的独特优势和广泛的应用场景&#xff0c;吸引了大量开发者的关注。本文将详细介绍Rust和Go的特点&#xff0c;并探讨它…

[Linux][Shell][Shell逻辑控制]详细讲解

目录 1.if 判断1.if-then2.if-then-else3.elif4.case5.实际上手 2.条件测试0.事前说明1.test 命令2.[]3.双括号1.(())2.[[]] 4.实际上手 3.循环1.for2.while3.until命令4.控制循环1.break2.continue 5.处理循环的输出 1.if 判断 1.if-then 语法&#xff1a;if command thenco…

代码随想录算法训练营DAY60|并查集理论基础、寻找存在的路径

并查集理论基础 并查集主要有两个功能&#xff1a; 将两个元素添加到一个集合中。判断两个元素在不在同一个集合 复杂度分析 空间复杂度&#xff1a; O(n) &#xff0c;申请一个father数组。路径压缩后的并查集时间复杂度在O(logn)与O(1)之间&#xff0c;且随着查询或者合并操…

大数据------JavaWeb------VueElement(完整知识点汇总)

Vue 定义 Vue是一套前端框架&#xff0c;可以免除原生JavaScript中的DOM操作&#xff0c;简化书写 之前所学的MyBatis框架是用来简化JDBC代码编写的&#xff1b;而Vue是前端框架&#xff0c;用来简化JavaScript代码编写的 在Axios与JSON综合案例的添加中有大量的DOM操作&#…

Ubuntu 22.04.4 LTS (linux) 安装 Auditd 安全审计

1 安装auditd sudo apt update sudo apt-get install auditd 2 修改配置 #sudo vim /etc/audit/auditd.conf #日志文件位置 log_file /var/log/audit/audit.log #日志文件大小(Mb) max_log_file 8 #日志文件数量 num_logs 53 启动服务 sudo systemctl restart aud…

【密码学】数字签名

一、数字签名的基本概念 数字签名是一种用于验证电子文档完整性和身份认证的密码学技术。它通过使用公钥加密体系中的私钥对文档的一部分&#xff08;通常是文档的摘要&#xff09;进行加密&#xff0c;从而创建一个“签名”。这个签名可以附在文档上&#xff0c;或作为一个单独…

vue3实现vuedraggable实现拖拽到垃圾桶图标位置进行删除

当使用Vue 3和vuedraggable库时&#xff0c;你可以按照以下方式实现拖拽到垃圾桶图标位置进行删除的功能&#xff1a; 首先&#xff0c;确保你已经安装了vuedraggable库。如果没有安装&#xff0c;可以通过以下命令进行安装&#xff1a; vuedraggable 和vue-draggable-plus使…

力扣636.函数的独占时间

力扣636.函数的独占时间 用一个对组栈存每个start数据&#xff0c;first为编号&#xff0c;second为开始时间 start时&#xff1a;若栈为空 直接入栈 若不为空 处理前一段已独占的时间 end时&#xff1a;将自己的独占时间处理了 若栈非空 将栈顶元素的开始时间更新为当前时间1因…

如何将HEVC格式的视频转换为无损、未压缩的MP4格式视频?

在和大家分享视频格式转换之前&#xff0c;先跟大家分享一下HEVC格式的视频到底是什么文件&#xff1f;压缩原理是什么&#xff1f;了解了它的本质之后&#xff0c;我们就可以知道如何保证视频高清无损了。 如何将HEVC格式的视频转换为无损、未压缩的MP4格式视频&#xff1f; …

【Flask从入门到精通:第二课:flask加载项目配置的二种方式、路由的基本定义和终端运行】

flask加载项目配置的二种方式 # 1. 导入flask核心类 from flask import Flask# 2. 初始化web应用程序的实例对象 app Flask(__name__)"""第一种&#xff1a;flask项目加载站点配置的方式""" # app.config["配置项"] 配置项值 # app…

逐步实践复现 SELF-RAG

SELF-RAG 简介 SELF-RAG&#xff08;Self-Reflective Retrieval-Augmented Generation&#xff09;是一种检索增强生成&#xff08;RAG&#xff09;的框架&#xff0c;它通过自我反思学习检索、生成和批判&#xff0c;以提高大型语言模型&#xff08;LLM&#xff09;的质量和真…

通用业务指标管理系统设计

设计一个通用业务指标管理系统&#xff0c;旨在帮助企业全面监控和管理关键业绩指标(KPIs)&#xff0c;以驱动决策制定和业务优化。以下是一个综合性的设计方案&#xff0c;涵盖核心功能模块、技术架构、以及用户体验设计要点&#xff1a; 1. 核心功能模块 目标设定与分解 战…

「C++系列」一篇文章说透【存储类】

文章目录 一、C 存储类1. 类的定义2. 对象的创建3. 对象在内存中的布局4. 对象的存储位置 二、auto 存储类1. auto的基本用法2. auto与存储类的关系1) 自动存储类&#xff08;最常见的&#xff09;2) 静态存储类3) 动态存储类&#xff08;通过new&#xff09; 三、register 存储…

C标准库读写文件

函数介绍 库变量 变量描述size_t无符号整数类型&#xff0c;是sizeof关键字的结果&#xff0c;表示对象大小FILE文件流类型&#xff0c;适合存储文件流信息的对象类型 库宏 宏描述NULL空指针常量EOF表示已经到达文件结束的负整数stderr、stdin、stdout指向FILE类型的指针&a…

react 中useState 使用Immer 简化数据更改操作数组、对象

如果你不想改变你的状态结构&#xff0c;你可能更喜欢嵌套传播的捷径。Immer 是一个流行的库&#xff0c;它允许你使用方便但可变的语法进行编写&#xff0c;并负责为你生成副本。使用 Immer&#xff0c;你编写的代码看起来就像你是 “打破规则” 并且正在改变一个对象&#xf…

js【详解】声明常量和变量 const let var

声明常量 const 声明常量时&#xff0c;必须赋值&#xff01;声明的常量赋值后&#xff0c;不能修改&#xff08;运行时会报错&#xff09;ES6 新增语法有块级作用域 const webName EC编程俱乐部常量不可变的本质 常量赋值值类型数据后&#xff0c;不能再赋其他值&#xff0…

【数智化案例展】吉林省消防救援总队——基于大语言模型的119智慧助手

‍ 嘉诚信息案例 本项目案例由嘉诚信息投递并参与数据猿与上海大数据联盟联合推出的《2024中国数智化转型升级创新服务企业》榜单/奖项评选。 大数据产业创新服务媒体 ——聚焦数据 改变商业 随着信息时代的迅猛发展&#xff0c;消防人员正面临前所未有的知识爆炸挑战。为了高…

功能丰富的开源协作式知识库系统outline

语雀飞书平替快速协作式的团队知识库提供一个美观、易于使用的界面允许团队成员以实时方式协作编辑文档支持Markdown-i68爱六八,链接你我他&#xff1a;https://i68.ltd项目仓库&#xff1a;GitHub - outline/outline: The fastest knowledge base for growing teams. Beautifu…

day30--56. 合并区间+ 738.单调递增的数字

一、56. 合并区间 题目链接&#xff1a;https://leetcode.cn/problems/merge-intervals/ 文章讲解&#xff1a;https://programmercarl.com/0056.%E5%90%88%E5%B9%B6%E5%8C%BA%E9%97%B4.html 视频讲解&#xff1a;https://www.bilibili.com/video/BV1wx4y157nD 1.1 初见思路 …

数据库第四次练习

数据准备 创建两张表&#xff1a;部门&#xff08;dept&#xff09;和员工&#xff08;emp&#xff09;&#xff0c;并插入数据&#xff0c;代码如下 create table dept( dept_id int primary key auto_increment comment 部门编号, dept_name char(20) comment 部门名称 ); in…