kubectl使用及源码阅读

目录

  • 概述
  • 实践
    • 样例
      • yaml 中的必须字段
    • kubectl 代码原理
      • kubectl 命令行设置pprof 抓取火焰图
        • kubectl 中的 cobra
    • 七大分组命令
      • kubectl create
      • createCmd中的builder模式
      • createCmd中的visitor访问者模式
      • 外层VisitorFunc分析
  • 结束

概述

k8s 版本 v1.24.16

kubectl的职责

  • 1.主要的工作是处理用户提交的东西(包括，命令行参数，yaml文件等)
  • 2.将用户提交的这些东西组织成一个数据结构体
  • 3.再将其发送给 api server

实践

文章名链接
linux k8s 源码编译及单集群测试地址
k8s源码debug地址

样例

cat test/fixtures/doc-yaml/user-guide/pod.yaml

apiVersion: v1
kind: Pod
metadata:
  name: nginx
  labels:
    app: nginx
spec:
  containers:
  - name: nginx
    image: nginx
    ports:
    - containerPort: 80
字段名含义
kindPod
metadata.name
spec.containers.name
spec.containers.imageimage名称:版本

对象规约(Spec) 与状态 (Status)

  • 几乎每个 Kubernetes 对象包含两个嵌套的对象字段，它们负责管理对象的配置：对象 spec (规约) 和对象 status (状态)
  • 对于具有 spec 的对象，必须在创建对象时设置具体内容，描述你希望对象所具有的特征：期望状态 (Desired State)

yaml 中的必须字段

  • 在想要创建的 Kubernetes 对象对应的 yaml 文件中，需要配置如下的字段：
    • apiVersion - 创建该对象所使用的 Kubernetes API 的版本
    • kind - 想要创建的对象的类别
    • metadata - 帮助唯一标识对象的一些数据，包括一个 name 字符串、UID和可选的 namespace
[root@test kubernetes]# ./cluster/kubectl.sh get pods
NAME    READY   STATUS    RESTARTS   AGE
nginx   1/1     Running   0          89s
字段名含义
NAMEnginx就是对应yaml中metadata.name
READY就绪个数
STATUS当前的状态，RUNNING表示运行中
RESTARTS重启的次数，代表没有重启过
AGE运行的时长

kubectl 代码原理

  • 1.从命令行和 yaml 文件中获取信息
  • 2.通过 Builder 模式并将其转成一系列的资源
  • 3.最后用 Visitor 模式来迭代处理这些 Resources

源码位置
在这里插入图片描述

kubectl 命令行设置pprof 抓取火焰图

kubectl 中的 cobra
  • 底层函数 NewKubectlCommand 解析
  • 在 PersistentPreRunE 设置 prrof 采集相关指令
  • 在 PersistentPostRunE 设置了 pprof 统计结果落盘
  • 执行采集 pprof cpu 的 kubelet 命令
kubectl.go --> command := cmd.NewDefaultKubectlCommand()
	cmd.go --> return NewDefaultKubectlCommandWithArgs(KubectlOptions{ -->cmd := NewKubectlCommand(o)

# cpu.pprof 文件在当前命令执行目录下
kubectl get node --profile=cpu --profile-output=cpu.pprof
# ll
# 使用 go 工具将 pprof 转换成 svg  火焰图
go tool pprof -svg cpu.pprof > kubectl_get_node_cpu.svg
# 下载下来，在浏览器打开

七大分组命令

kubectl.go --> command := cmd.NewDefaultKubectlCommand()
	cmd.go --> var defaultConfigFlags = genericclioptions.NewConfigFlags(true).WithDeprecatedPasswordFlag().WithDiscoveryBurst(300).WithDiscoveryQPS(50.0) --> f := cmdutil.NewFactory(matchVersionKubeConfigFlags) --> 	proxyCmd := proxy.NewCmdProxy(f, o.IOStreams)
	proxyCmd.PreRun = func(cmd *cobra.Command, args []string) {
		kubeConfigFlags.WrapConfigFn = nil
	}

groups := templates.CommandGroups{
	{
		Message: "Basic Commands (Beginner):",
		Commands: []*cobra.Command{
			create.NewCmdCreate(f, o.IOStreams),
			expose.NewCmdExposeService(f, o.IOStreams),
			run.NewCmdRun(f, o.IOStreams),
			set.NewCmdSet(f, o.IOStreams),
		},
	},
	{
		Message: "Basic Commands (Intermediate):",
		Commands: []*cobra.Command{
			explain.NewCmdExplain("kubectl", f, o.IOStreams),
			getCmd,
			edit.NewCmdEdit(f, o.IOStreams),
			delete.NewCmdDelete(f, o.IOStreams),
		},
	},
	{
		Message: "Deploy Commands:",
		Commands: []*cobra.Command{
			rollout.NewCmdRollout(f, o.IOStreams),
			scale.NewCmdScale(f, o.IOStreams),
			autoscale.NewCmdAutoscale(f, o.IOStreams),
		},
	},
	{
		Message: "Cluster Management Commands:",
		Commands: []*cobra.Command{
			certificates.NewCmdCertificate(f, o.IOStreams),
			clusterinfo.NewCmdClusterInfo(f, o.IOStreams),
			top.NewCmdTop(f, o.IOStreams),
			drain.NewCmdCordon(f, o.IOStreams),
			drain.NewCmdUncordon(f, o.IOStreams),
			drain.NewCmdDrain(f, o.IOStreams),
			taint.NewCmdTaint(f, o.IOStreams),
		},
	},
	{
		Message: "Troubleshooting and Debugging Commands:",
		Commands: []*cobra.Command{
			describe.NewCmdDescribe("kubectl", f, o.IOStreams),
			logs.NewCmdLogs(f, o.IOStreams),
			attach.NewCmdAttach(f, o.IOStreams),
			cmdexec.NewCmdExec(f, o.IOStreams),
			portforward.NewCmdPortForward(f, o.IOStreams),
			proxyCmd,
			cp.NewCmdCp(f, o.IOStreams),
			auth.NewCmdAuth(f, o.IOStreams),
			debug.NewCmdDebug(f, o.IOStreams),
		},
	},
	{
		Message: "Advanced Commands:",
		Commands: []*cobra.Command{
			diff.NewCmdDiff(f, o.IOStreams),
			apply.NewCmdApply("kubectl", f, o.IOStreams),
			patch.NewCmdPatch(f, o.IOStreams),
			replace.NewCmdReplace(f, o.IOStreams),
			wait.NewCmdWait(f, o.IOStreams),
			kustomize.NewCmdKustomize(o.IOStreams),
		},
	},
	{
		Message: "Settings Commands:",
		Commands: []*cobra.Command{
			label.NewCmdLabel(f, o.IOStreams),
			annotate.NewCmdAnnotate("kubectl", f, o.IOStreams),
			completion.NewCmdCompletion(o.IOStreams.Out, ""),
		},
	},
}

kubectl create

// 进入口
create.NewCmdCreate(f, o.IOStreams)

// 核心的cmd.Run函数
// 校验文件参数
if cmdutil.IsFilenameSliceEmpty(o.FilenameOptions.Filenames, o.FilenameOptions.Kustomize) {
	ioStreams.ErrOut.Write([]byte("Error: must specify one of -f and -k\n\n"))
	defaultRunFunc := cmdutil.DefaultSubCommandRun(ioStreams.ErrOut)
	defaultRunFunc(cmd, args)
	return
}

// 完善并填充所需字段 
cmdutil.CheckErr(o.Complete(f, cmd))
// 校验参数
cmdutil.CheckErr(o.ValidateArgs(cmd, args))
// 核心的RunCreate
// 发送请求与 api server 通信
cmdutil.CheckErr(o.RunCreate(f, cmd))

createCmd中的builder模式

createCmd中的builder建造者设计模式

// 快速定位代码
cmdutil.CheckErr(o.RunCreate(f, cmd)) -->
r := f.NewBuilder().
		Unstructured().
		Schema(schema).
		ContinueOnError().
		NamespaceParam(cmdNamespace).DefaultNamespace().
		FilenameParam(enforceNamespace, &o.FilenameOptions).
		LabelSelectorParam(o.Selector).
		Flatten().
		Do()

在这里插入图片描述

createCmd中的visitor访问者模式

  • 访问都模式(Visitor Pattern) 是一种将数据结构与数据操作分离的设计模式
  • 指封装一些作用于某种数据结构中的各元素的操作
  • 可以在不改变数据结构的前提下定义作用于这些元素的新的操作
  • 属于行为型设计模式

使用场景：

  • 数据结构稳定，作用于数据结构的操作经常变化的场景
  • 需要数据结构与数据操作分享的场景
  • 需要对不同数据类型(元素)进行操作，而不使用分支判断具体类型的场景
// 快速定位代码
cmdutil.CheckErr(o.RunCreate(f, cmd)) --> err = r.Visit(func(info *resource.Info, err error) error {

// 注意 Visit 是由 Builder 中 FilenameParam 构建的
r := f.NewBuilder().
		...
		// 构建 Visit
		FilenameParam(enforceNamespace, &o.FilenameOptions).
		...
		// 创建 Visit
		Do()
// 定位
FilenameParam --> b.Path(recursive, matches...) --> visitors, err := ExpandPathsToFileVisitors(b.mapper, p, recursive, FileExtensions, b.schema) -->
		visitor := &FileVisitor{
			Path:          path,
			StreamVisitor: NewStreamVisitor(nil, mapper, path, schema),
		}

FilenameParam --> b.Path(recursive, matches…) 位置
在这里插入图片描述

// NewStreamVisitor is a helper function that is useful when we want to change the fields of the struct but keep calls the same.
func NewStreamVisitor(r io.Reader, mapper *mapper, source string, schema ContentValidator) *StreamVisitor {
	return &StreamVisitor{
		Reader: r,
		mapper: mapper,
		Source: source,
		Schema: schema,
	}
}

// 解析 yaml 或者 json 配置
// Visit implements Visitor over a stream. StreamVisitor is able to distinct multiple resources in one stream.
func (v *StreamVisitor) Visit(fn VisitorFunc) error {
	d := yaml.NewYAMLOrJSONDecoder(v.Reader, 4096)
	for {
		ext := runtime.RawExtension{}
		if err := d.Decode(&ext); err != nil {
			if err == io.EOF {
				return nil
			}
			return fmt.Errorf("error parsing %s: %v", v.Source, err)
		}
		// TODO: This needs to be able to handle object in other encodings and schemas.
		ext.Raw = bytes.TrimSpace(ext.Raw)
		if len(ext.Raw) == 0 || bytes.Equal(ext.Raw, []byte("null")) {
			continue
		}
		if err := ValidateSchema(ext.Raw, v.Schema); err != nil {
			return fmt.Errorf("error validating %q: %v", v.Source, err)
		}
		info, err := v.infoForData(ext.Raw, v.Source)
		if err != nil {
			if fnErr := fn(info, err); fnErr != nil {
				return fnErr
			}
			continue
		}
		if err := fn(info, nil); err != nil {
			return err
		}
	}
}

// 上面方法中，重点如下代码
info, err := v.infoForData(ext.Raw, v.Source)

// obj 代表 k8s的对象
// gvk 代表 Group/Version/Kind 的缩写
obj, gvk, err := m.decoder.Decode(data, nil, nil)

外层VisitorFunc分析

  • 如查出错即返回错误
  • DryRunStrategy 代表试运行策略
    • 默认为 None 代表不试运行
    • client 代表客户端试运行，不发送请求至 server
    • server 点服务端试运行，发送请求，但是如果会改变状态的话就不做
err = r.Visit(func(info *resource.Info, err error) error { --> if o.DryRunStrategy != cmdutil.DryRunClient {  --> Create(info.Namespace, true, info.Object)(最终创建资源)

结束

kubectl使用及进阶 至此结束。

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

如若内容造成侵权/违法违规/事实不符，请联系我们进行投诉反馈qq邮箱809451989@qq.com，一经查实，立即删除！

相关文章

供应链大数据：穿越经济迷雾的指南针

供应链大数据：穿越经济迷雾的指南针

随着经济形势的变幻莫测，企业运营面临着前所未有的挑战。在这个充满不确定性的时代，供应链大数据如同一盏明亮的指南针，为企业提供精准的方向指引。下面，我们将深入探讨供应链大数据如何帮助企业洞察市场趋势、优化库存管理、降低…
阅读更多...
2024年ODE(云端集成开发环境)排行榜

2024年ODE(云端集成开发环境)排行榜

✍️作者简介：小北编程（专注于HarmonyOS、Android、Java、Web、TCP/IP等技术方向） 🐳博客主页： 开源中国、稀土掘金、51cto博客、博客园、知乎、简书、慕课网、CSDN 🔔如果文章对您些帮助请👉关…
阅读更多...
获取tensorflow lite模型指定中间层的输出

获取tensorflow lite模型指定中间层的输出

以mobilenet v2为例子，我已经训练好了模型，有tflite格式和onnx格式两种模型的权重文件，我想获取tflite模型在推理阶段neck部分的输出。 查看onnx模型得到neck最后一层位置 使用netron查看onnx模型结构 从name中能知道Reshape是neck的最后一…
阅读更多...
[c++] char * 和 std::string

[c++] char * 和 std::string

1 char * 和 std::string 的区别 char * 字符串是常量字符串，不能修改；std::string 指向的字符串可以修改 实例代码如下图所示，s1 和 s2 均是常量字符串，字符串常量保存在只读数据区，是只读的，不能写&…
阅读更多...
QT GUI编程常用控件学习

QT GUI编程常用控件学习

1 GUI编程应该学什么 2 QT常用模块结构 QtCore: 包含了核心的非GUI的功能。主要和时间、文件与文件夹、各种数据、流、URLs、mime类文件、进程与线程一起使用 QtGui: 包含了窗口系统、事件处理、2D图像、基本绘画、字体和文字类 QtWidgets: 包含了一些列创建桌面应用的UI元素…
阅读更多...
python input 输入

python input 输入

input()函数包含四个方面：input()函数的使用/结果的赋值/数据类型/结果的强制转换。是实现人机互动沟通的关键，需要在终端出输入信息。我们可以把input()函数当作一扇链接现实世界与代码世界的门， 如下图 先看一个例子：　 运行后终…
阅读更多...
生产线辅料加注机加注量的可视化操作系统无线通讯应用

生产线辅料加注机加注量的可视化操作系统无线通讯应用

挖掘机装配生产线在生产过程中，需要在下车装配、液压测试、发动机部件装配等过程中添加液压油、柴油、润滑油、防冻液、冷媒等辅料。加注机作为必要的辅料加注设备，将设定辅料输入到挖掘机对应输送管道中。 客户需求是想实现挖掘机装配线加注机与操作台…
阅读更多...
Linux基础命令—系统服务

Linux基础命令—系统服务

基础知识 centos系统的开机流程 1)通电 2)BIOS硬件检查 3)MBR引导记录 mbr的引导程序 加载引导程序 让硬件加载操作系统内核 MBR在第一个磁盘第一个扇区 总大小512字节 mbr: 1.引导程序: 占用446字节用于引导硬件,加载引导程序 2.分区表: 总共占…
阅读更多...
关系型数据库事务的隔离级别： 读未提交, 读已提交, 可重复读, 序列化。

关系型数据库事务的隔离级别： 读未提交, 读已提交, 可重复读, 序列化。

关系型数据库事务的隔离级别： 读未提交, 读已提交, 可重复读, 序列化。 事务的四性: 原子性，一致性，隔离性，持久性。(4项) 事务的隔离级别： 读未提交, 读已提交, 可重复读, 序列化。(4项) 并发事务可能引起: 脏读, …
阅读更多...
【计算机网络】1.4 接入网和物理媒体

【计算机网络】1.4 接入网和物理媒体

1.4 接入网和物理媒体 问题：怎样将端系统和边缘路由器连接？ 答：有线方式（住宅接入网络、单位接入网络等）或无线方式（无线接入网络）。 有线接入方式 光纤同轴混合网是基于已有的有线电视网开发的…
阅读更多...
中年人，收起你的大方

中年人，收起你的大方

作者| Mr.K 编辑| Emma 来源| 技术领导力(ID：jishulingdaoli) 先和大家分享一件最近发生在K哥身上的真实故事。K哥前同事老G托我帮他一位朋友推荐工作，说他的这个朋友失业好几个月了，上有老下有小很不容易，让我无论如何也要想办…
阅读更多...
IDEA安装配置以及安装配置Maven

IDEA安装配置以及安装配置Maven

IEDA官方下载地址，有专业版（收费，破解），社区版（免费） 下载 IntelliJ IDEA – 领先的 Java 和 Kotlin IDE 安装配置Maven 1.解压apache-maven-3.6.3-bin.zip，安装maven到D盘softwar…
阅读更多...
【YOLO v5 v7 v8小目标改进】SPD-Conv

【YOLO v5 v7 v8小目标改进】SPD-Conv

SPD-Conv 提出背景SPD-Conv YOLO v5 小目标改进定义 SPD-Conv导入SPD模块修改 .yaml 文件 YOLO v7 小目标改进YOLO v8 小目标改进 提出背景 论文：https://arxiv.org/pdf/2208.03641v1.pdf 代码：https://github.com/labsaint/spd-conv 文章提出一个新的…
阅读更多...
代码随想录算法刷题训练营day23

代码随想录算法刷题训练营day23

代码随想录算法刷题训练营day23：LeetCode(669)修剪二叉搜索树、LeetCode(108)将有序数组转换为二叉搜索树、LeetCode(538)把二叉树转化为累加树 LeetCode(669)修剪二叉搜索树 题目 代码 /*** Definition for a binary tree node.* public class TreeNode {* …
阅读更多...
数据安全之路：深入了解MySQL的行锁与表锁机制

数据安全之路：深入了解MySQL的行锁与表锁机制

欢迎来到我的博客，代码的世界里，每一行都是一个故事 数据安全之路：深入了解MySQL的行锁与表锁机制 前言基础innodb中锁与索引的关系如何避免表锁 前言 在当今数据密集的应用中，数据库锁成为了确保数据一致性和并发操作的关键工具…
阅读更多...
Linux字符设备驱动中同类型多设备节点的创建---一个驱动程序支持多个同类型设备

Linux字符设备驱动中同类型多设备节点的创建---一个驱动程序支持多个同类型设备

文章目录 前言1 代码解析1.1 驱动层1.2 应用层 2 运行结果总结 前言 本期分享的内容相对比较简单，那就是同时注册多个同类型的字符设备驱动，那么这样我们就可以同时支持多个同类型的设备了！下面来带大家看一下： 1 代码解析 1.1 …
阅读更多...
【Flink精讲】Flink性能调优：内存调优

【Flink精讲】Flink性能调优：内存调优

内存调优 内存模型 JVM 特定内存 JVM 本身使用的内存，包含 JVM 的 metaspace 和 over-head 1） JVM metaspace： JVM 元空间 taskmanager.memory.jvm-metaspace.size，默认 256mb 2） JVM over-head 执行开销&#xff1…
阅读更多...
深入探讨基于大语言模型的数据标注

深入探讨基于大语言模型的数据标注

文章地址： https://arxiv.org/pdf/2402.13446 数据标注是将原始数据用相关信息进行标注，对于提高机器学习模型的效果至关重要。然而，这一过程往往需要大量人力和资金支持。先进大语言模型（LLMs）的出现，例如…
阅读更多...
小程序--事件处理

小程序--事件处理

一、事件对象 给小程序的事件传递参数&#xff0c;有以下两种方法&#xff1a; 1、自定义属性 <view class"item" wx:for"{{ 5 }}" wx:key"*this" data-index"{{index}}" bind:tap"onClick"></view> Page({o…
阅读更多...
spss常用检验方法

spss常用检验方法

spss常用检验方法 1 数据是否符合正态分布1.1符合正态分布1.1.1怎样的数据符合正态分布1.1.2 spss怎么统计正态分布1.1.3 方差齐性检验1.1.4 具体统计学分析 1.2 不符合正态分布1.2.1 Mann-Whitney U检验1.2.2 Wilcoxon符号秩检验1.2.3 Kruskal-Wallis H检验1.2.4 Friedman检验…
阅读更多...
最新文章

Copyright @ 2022~2023