Kubernetes对象深入学习之五：TypeMeta无效之谜

欢迎访问我的GitHub

这里分类和汇总了欣宸的全部原创(含配套源码)：https://github.com/zq2599/blog_demos

本篇概览

  • 本文是《Kubernetes对象深入学习之五》系列的第五篇，从前文的分析也能看出，代表对象类型的schema.ObjectKind，于对象而言是至关重要的，那是它的类型和身份，既然如此，与之有关的问题也不能放过，因此本篇就来看一个对象类型相关的问题，本文由以下内容组成：
  1. 复现问题：我的代码中获取的对象类型为空
  2. 问题原因
  3. 为什么会有这个问题？
  4. 这个问题有解吗？

复现问题

  • 问题很容易复现，回顾《Kubernetes对象深入学习之四：对象属性编码实战》的代码，controller.go有下面这么一段代码，作用是在controller监听到对象变化时，将对象的ObjectMeta内容在控制台打印出来，现在咱们在黄色箭头前面添加两端代码
    在这里插入图片描述
  • 新增的代码是下面这些，先用现成的方法做一次提取，得到Kind和APIVersion，再尝试直接转换成objectruntime.Object类型获取GVK
// 第一次尝试：通过公共方法转为Type接口
objType, err := meta.TypeAccessor(obj)
if err != nil {
	klog.Errorf("TypeAccessor [%s], failed with %v", key, err)
	return err
}

fmt.Printf("** 通过公共方法获取Kind, kind [%s], version [%s]\n", objType.GetKind(), objType.GetAPIVersion())

// 第二次尝试：亲自尝试强转
runtimeObj, _ := obj.(objectruntime.Object)
fmt.Printf("** 强转获取Kind: %v\n", runtimeObj.GetObjectKind().GroupVersionKind())
  • 修改后整体效果如下，黄框中是本次新增内容
    在这里插入图片描述
  • 程序启动后，打印日志如下，可见不论是哪种方式，kind和version的值都是空
I0827 01:15:58.890491 2945049 controller.go:144] Starting Pod controller
** 通过公共方法获取Kind, kind [], version []
** 强转获取Kind: /, Kind=
** 通过公共方法获取Kind, kind [], version []
** 强转获取Kind: /, Kind=
** 通过公共方法获取Kind, kind [], version []
** 强转获取Kind: /, Kind=
  • 好了，现在问题已复现：TypeMeta内容为空，接下来去寻找问题原因

问题原因

  • 咱们按照顺序捋一下代码，在main.go中调用了CreateAndStartController来创建controller，此时指定了类型是&v1.Pod{}
    在这里插入图片描述

  • 在CreateAndStartController方法内会调用NewListWatchFromClient来创建ListWatcher，指定了resource就是刚才传入的pods
    在这里插入图片描述

  • 继续展开，就看到了关键代码NewFilteredListWatchFromClient方法，这里指出了list操作的具体实现，该方法其余代码略去不看了：

func NewFilteredListWatchFromClient(c Getter, resource string, namespace string, optionsModifier func(options *metav1.ListOptions)) *ListWatch {
	listFunc := func(options metav1.ListOptions) (runtime.Object, error) {
		optionsModifier(&options)
		return c.Get().
			Namespace(namespace).
			Resource(resource).
			VersionedParams(&options, metav1.ParameterCodec).
			Do(context.TODO()).
			Get()
	}
	
	// 剩余的代码省略不看
	...
}
  • 注意，重点来了，先展开上面的Do方法，这里面发起了远程请求，获取资源列表，并且指定transformResponse方法用来处理收到的响应
func (r *Request) Do(ctx context.Context) Result {
	var result Result
	err := r.request(ctx, func(req *http.Request, resp *http.Response) {
		result = r.transformResponse(resp, req)
	})
	if err != nil {
		return Result{err: err}
	}
	return result
}
  • 这个transformResponse方法的代码太多，我们只关注重点，就是这个decoder对象，记住这个decoder
    在这里插入图片描述
  • 看完了Do方法，再来看Get方法，关键代码是黄色箭头指出的部分：使用decoder对响应的body进行处理
    在这里插入图片描述
  • 再来看这个Decode方法的内容（apimachinery@v0.22.8/pkg/runtime/helper.go），很明显，这里故意调用了SetGroupVersionKind方法，入参是个新的GroupVersionKind对象，如此一来，所有类型有关的信息就被清除了
// Decode does not do conversion. It removes the gvk during deserialization.
func (d WithoutVersionDecoder) Decode(data []byte, defaults *schema.GroupVersionKind, into Object) (Object, *schema.GroupVersionKind, error) {
	obj, gvk, err := d.Decoder.Decode(data, defaults, into)
	if obj != nil {
		kind := obj.GetObjectKind()
		// clearing the gvk is just a convention of a codec
		kind.SetGroupVersionKind(schema.GroupVersionKind{})
	}
	return obj, gvk, err
}
  • 至此，真相大白，kubernetes官方在处理api-server的响应内容时，刻意将TypeMeta清理掉了

为什么会有这个问题？

  • 对于这么做的原因，首先是个人猜测，回到main.go，如下图，作为使用方，既然已经明确了要监听的资源是pod，那么得到的结果自然就只能是v1.Pod了，所以无需再从结果中获取类型，
    在这里插入图片描述
  • 至于根本原因，由于欣宸英语水平太差，未能从一群老外的讨论中得到明确答案，下面是和这个问题相关的pr和issue，可见抱有相同疑惑的人着实不少，并且这个问题已经持续多年，并且一直没有解决：
  • https://github.com/kubernetes/kubernetes/pull/59264#issuecomment-362579495
  • https://github.com/kubernetes/client-go/issues/541
  • https://github.com/kubernetes/client-go/issues/861
  • https://github.com/kubernetes/kubernetes/issues/80609

这个问题可以解决吗？

  • 老外有个建议，就是用DoRaw方法得到api-server响应的原始body，然后自己做反序列化，我这里试了下
    在这里插入图片描述
  • 日志打印出原始body内容如下，太长了只截取部分
raw : {"kind":"PodList","apiVersion":"v1","metadata":{"resourceVersion":"12435998"},"items":[{"metadata":{"name":"nginx-deployment-78f6b696d9-cr47w","generateName":"nginx-deployment-78f6b696d9-","namespace":"client-go-tutorials","uid":"645628af-0d20-4548-b15d-0faf9e03b733","resourceVersion":"12227486","creationTimestamp":"2023-08-13T11:15:59Z","labels":{"app":"nginx-app","business-service-type":"web","language":"c","pod-template-hash":"78f6b696d9","service-update-time":"20230813120623","type":"front-end"},"annotations":{"cni.projectcalico.org/containerID":"e94b7b0ebe60d1cada361f7a672b2c6df71f2d89c4b5c1ae4056f82dec6a78db","cni.projectcalico.org/podIP":"100.91.64.45/32","cni.projectcalico.org/podIPs":"100.91.64.45/32"},"ownerReferences":[{"apiVersion":"apps/v1","kind":"ReplicaSet","name":"nginx-deployment-78f6b696d9","uid":"642c39e7-814a-491f-9b4f-295f34e959a3","controller":true,"blockOwnerDeletion":true}],"managedFields":[{"manager":"kube-controller-manager","operation":"Update","apiVersion":"v1","time":"2023-08-13T11:15:59Z","fieldsType":"FieldsV1","fieldsV1":{"f:metadata":{"f:generateName":{},"f:labels":{".":{},"f:app":{},"f:business-service-type":{},"f:language":{},"f:pod-template-hash":{},"f:type":{}},"f:ownerReferences":{".":{},"k:{\"uid\":\"642c39e7-814a-491f-9b4f-295f34e959a3\"}":{}}},"f:spec":{"f:containers":{"k:{\"name\":\"nginx-container\"}":{".":{},"f:image":{},"f:imagePullPolicy":{},"f:name":{},"f:resources":{".":{},"f:limits":{".":{},"f:cpu":{},"f:memory":{}},"f:requests":{".":{},"f:cpu":{},"f:memory":{}}},"f:terminationMessagePath":{},"f:terminationMessagePolicy":{}}},"f:dnsPolicy":{},"f:enableServiceLinks":{},"f:restartPolicy":{},"f:schedulerName":{},"f:securityContext":{},"f:terminationGracePeriodSeconds":{}}}},
...
..
.
  • 拿到这样的json内容后，去工具网站转为go的数据结构代码，这样就能在代码中完成反序列化，例如：https://zxjson.com/json2go/， 如下图，转为go的数据接口
    在这里插入图片描述
  • 如此一来，跌跌撞撞的拿到了完整的json对象，当然了，这并不是个好的办法
  • 至此ypeMeta无效之谜已经解开，如果您有更好的解法或者更多官方消息，欢迎留言，感谢您的帮助

你不孤单，欣宸原创一路相伴

  1. Java系列
  2. Spring系列
  3. Docker系列
  4. kubernetes系列
  5. 数据库+中间件系列
  6. DevOps系列

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

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

相关文章

Shell编程之流程控制

Shell编程之流程控制

目录 if判断 case语句 for循环 while循环 if判断 语法： if [ 条件判断表达式 ] then 程序 elif [ 条件判断表达式 ] then 程序 else 程序 fi 注意： [ 条件判断表达式 ]，中括号和条件判断表达式之间必须有空格。if，elif…
阅读更多...
无涯教程-机器学习 - 矩阵图函数

无涯教程-机器学习 - 矩阵图函数

相关性是有关两个变量之间变化的指示，在前面的章节中，无涯教程讨论了Pearson的相关系数以及相关的重要性，可以绘制相关矩阵以显示哪个变量相对于另一个变量具有较高或较低的相关性。 在以下示例中，Python脚本将为Pima印度糖尿病数…
阅读更多...
Servlet学习总结（Request请求与转发，Response响应，Servlet生命周期、体系结构、执行流程等...）

Servlet学习总结（Request请求与转发，Response响应，Servlet生命周期、体系结构、执行流程等...）

Override 是Java中的注解（Annotation），它用于告诉编译器该方法是覆盖（重写）父类中的方法。当我们使用Override注解时，编译器会检查当前方法是否正确地覆盖了父类中的方法，如果没有覆盖成功&…
阅读更多...
Elasticsearch 集成---Spark Streaming 框架集成

Elasticsearch 集成---Spark Streaming 框架集成

一.Spark Streaming 框架介绍 Spark Streaming 是 Spark core API 的扩展，支持实时数据流的处理，并且具有可扩展， 高吞吐量，容错的特点。 数据可以从许多来源获取，如 Kafka ， Flume ， Kin…
阅读更多...
Scala集合继承体系图

Scala集合继承体系图

Scala集合简介 1） Scala 的集合有三大类：序列 Seq、集Set、映射 Map，所有的集合都扩展自 Iterable特质。 2） 对于几乎所有的集合类，Scala 都同时提供了可变和不可变的版本，分别位于以下两个包 不可变集合…
阅读更多...
[C++网络协议] I/O复用

[C++网络协议] I/O复用

具有代表性的并发服务器端实现模型和方法： 多进程服务器：通过创建多个进程提供服务。 多路复用服务器：通过捆绑并统一管理I/O对象提供服务。✔ 多线程服务器：通过生成与客户端等量的线程提供服务。 目录 1. I/O复用 2. select函…
阅读更多...
Vue:关于声明式导航中的 跳转、高亮、以及两个类名的定制

Vue:关于声明式导航中的 跳转、高亮、以及两个类名的定制

声明式导航-导航链接 文章目录 声明式导航-导航链接router-link的两大特点（能跳转、能高亮）声明式导航-两个类名定制两个高亮类名 实现导航高亮，实现方式其实，css，JavaScript , Vue ,都可以实现。其实关于路由导航&…
阅读更多...
Android Studio 的github 工程克隆

Android Studio 的github 工程克隆

上文介绍了Android Studio 里的"Git 建立和简单操作。本文介绍从github 上的工程fork 和clone到本地，然后学习和改进。 本文参考 https://learntodroid.com/how-to-use-git-and-github-in-android-studio/ 克隆clone Github 仓库： 先 Fork 你选择…
阅读更多...
stm32之25.FLASH闪存

stm32之25.FLASH闪存

打开标准库 源码--- int main(void) {uint32_t d;Led_init();key_init();/* 初始化串口1波特率为115200bps，若发送/接收数据有乱码，请检查PLL */usart1_init(115200);printf("this is flash test\r\n");/* 解锁FLASH（闪存&#xf…
阅读更多...
跨境做独立站，如何低成本引流？你的流量密码在这

跨境做独立站，如何低成本引流？你的流量密码在这

大家都知道，海外的消费习惯与国内不同，独立站一向是海外消费者的最喜欢的购物方式之一，这也吸引了许多跨境商家开设独立站。 独立站不同于其他的第三方平台，其他平台可以靠平台自身流量来获得转化，而独立站本身没有流…
阅读更多...
java八股文面试[多线程]——ThreadLocal底层原理和使用场景

java八股文面试[多线程]——ThreadLocal底层原理和使用场景

源码分析： ThreadLocal中定义了ThreadLocalMap静态内部类，该内部类中又定义了Entry内部类。 ThreadLocalMap定了 Entry数组。 Set方法： Get方法： Thread中定义了两个ThreaLocalMap成员变量： Spring使用ThreadLocal解…
阅读更多...
虚拟机Ubuntu20.04 网络连接器图标开机不显示怎么办

虚拟机Ubuntu20.04 网络连接器图标开机不显示怎么办

执行以下指令： sudo service network-manager stop sudo rm /var/lib/NetworkManager/NetworkManager.state sudo service network-manager start
阅读更多...
nginx压缩ttf文件 mine.types的作用

nginx压缩ttf文件 mine.types的作用

最近在运维过程中，前端提到发现在linux上下载某ttl文件（字体文件）太大，传输过程比较慢，于是就想着使用nginx的gzip进行压缩，经过不断尝试，终于发现在nginx的配置目录/etc/nginx/mine.types 文件…
阅读更多...
【UIPickerView-UIDatePicker-应用程序对象 Objective-C语言】

【UIPickerView-UIDatePicker-应用程序对象 Objective-C语言】

一、今天我们来学习三个东西 1.UIPickerView-UIDatePicker-应用程序对象 1.首先，来看数据选择控件 数据选择控件， 大家对这个数据选择控件，是怎么理解的， 1）数据选择控件，首先，是不是得有数据， 2）然后呢，你还得让用户能够选择， 3）最后，你还得是一个控件儿 那…
阅读更多...
国产ETLCloud VS 开源Kettle ETL对比分析

国产ETLCloud VS 开源Kettle ETL对比分析

ETLCloud VS Kettle ETLCloud和kettle是目前国内使用最广泛的两款免费ETL工具，本文将从多个角色对ETLCloud和kettle进行对比，方便用户快速了解到两款产品的差异并根据自已的需求选择相应的工具。 ETLCloud提供了对kettle流程的迁移功能，所以…
阅读更多...
文件上传漏洞-upload靶场5-12关

文件上传漏洞-upload靶场5-12关

文件上传漏洞-upload靶场5-12关通关笔记（windows环境漏洞） 简介 ​ 在前两篇文章中，已经说了分析上传漏的思路，在本篇文章中，将带领大家熟悉winodws系统存在的一些上传漏洞。 upload 第五关 （大小写绕过…
阅读更多...
gRPC-Gateway 快速实战

gRPC-Gateway 快速实战

今天来分享一波 gRPC-Gateway ， 之前咱们有分享过什么是 gRPC 及其使用方式，可以看看这些关于 gRPC 的历史文章： gRPC介绍 gRPC 客户端调用服务端需要连接池吗？ gRPC的拦截器 gRPC的认证 分享一下 gRPC- HTTP网关 I 今天主要是分…
阅读更多...
AI:05 - 基于深度学习的道路交通信号灯的检测与识别

AI:05 - 基于深度学习的道路交通信号灯的检测与识别

随着人工智能的快速发展，基于深度学习的视觉算法在道路交通领域中起到了重要作用。本文将探讨如何利用深度学习技术实现道路交通信号灯的检测与识别，通过多处代码实例展示技术深度。 道路交通信号灯是指示交通参与者行驶和停止的重要信号。准确地检测和识别交通信号灯对于智…
阅读更多...
最大子数组和【贪心算法】

最大子数组和【贪心算法】

最大子数组和 给你一个整数数组 nums ，请你找出一个具有最大和的连续子数组（子数组最少包含一个元素），返回其最大和。 子数组 是数组中的一个连续部分。 class Solution {public int maxSubArray(int[] nums) {//记录最大结果&…
阅读更多...
【陈老板赠书活动 - 11期】- 【MySQL从入门到精通】

【陈老板赠书活动 - 11期】- 【MySQL从入门到精通】

![ 陈老老老板🦸 👨‍💻本文专栏：赠书活动专栏（为大家争取的福利，免费送书） 👨‍💻本文简述：生活就像海洋,只有意志坚强的人,才能到达彼岸。 👨‍…
阅读更多...
最新文章

Copyright @ 2022~2023