kubernetes1.9源码阅读 kubernetes的watch包

本文涉及的产品
容器服务 Serverless 版 ACK Serverless,317元额度 多规格
容器服务 Serverless 版 ACK Serverless,952元额度 多规格
简介: 要理解kubernetes的list-watch机制,首先应该熟悉理解kubernetes的watch包中的各种实现以及原理。这篇文章将从代码实现看看kubernetes的watch包实现。从kubernetes1.6之后,kubernetes的watch包抽取到了apimachinery这个项目下。

要理解kubernetes的list-watch机制,首先应该熟悉理解kubernetes的watch包中的各种实现以及原理。这篇文章将从代码实现看看kubernetes的watch包实现。从kubernetes1.6之后,kubernetes的watch包抽取到了apimachinery这个项目下。

watch包文件说明


watch包主要包含5个文件:watch.go,mux.go,filter.go,streamwatch.go,util.go。下面是对这五个文件作简单的说明:

1. watch.go 主要是接口定义及对interface的三种实现的封装。

2. mux.go 主要是事件广播器。

3. filter.go 主要是对事件的过滤。

4. streamwatch.go 主要是对decoder接口实现的封装。

5. util.go 主要是对满足条件时间的过滤。

watch.go文件

watch.go定义了接口,k8s中说有的event事件统一都实现了interface接口,interface接口的定义如下:

1. Event结构体,主要包括:事件类型Type和事件发生的对象Object,k8s中所有的对象(比如:pod、service、rc、dp….)都是runtime.Object;

2. watch.Interface中主要有两个方法:分别是对事件的监听结果ResultChan()和停止监听Stop()方法;

700

3. watch.go还包括对Interface的三种实现的封装:emptyWatch、fakerWatch

、racefreeWatch,fakerWatch和racefreeWatch是线程安全的;

mux.go文件

mux.go文件中主要包括了事件广播器Broadcaster和广播器的观察者broadcasterWatcher;

1. Broadcaster包括watchers,当创建一个Broadcaster时,Broadcaster会开一个协程接收所有的事件及发送事件到所有注册的watcher。保证Broadcaster的所有的watcher一直都能不断的接收到Broadcaster发送过来的事件;

2. broadcastWatcher实现了watch.Interface,包括:resultChan方法和stop方法;

3. 在kube-scheduler中,会创建record.NewBroadcaster(),发送event到logging函数,参见之前的文章:kubernetes1.8 kube-scheduler源码阅读

700

filter.go文件

filter.go文件也是主要对interface的的实现,加上了事件过滤的方法,这样的话,就可以只watcher满足一定条件的事件了;

700

同时,filter.go中的Recorder结构体,记录watcher所接收到的所有的事件;

700本文转自kubernetes中文社区- kubernetes1.9源码阅读 kubernetes的watch包

相关实践学习
容器服务Serverless版ACK Serverless 快速入门:在线魔方应用部署和监控
通过本实验,您将了解到容器服务Serverless版ACK Serverless 的基本产品能力,即可以实现快速部署一个在线魔方应用,并借助阿里云容器服务成熟的产品生态,实现在线应用的企业级监控,提升应用稳定性。
容器应用与集群管理
欢迎来到《容器应用与集群管理》课程,本课程是“云原生容器Clouder认证“系列中的第二阶段。课程将向您介绍与容器集群相关的概念和技术,这些概念和技术可以帮助您了解阿里云容器服务ACK/ACK Serverless的使用。同时,本课程也会向您介绍可以采取的工具、方法和可操作步骤,以帮助您了解如何基于容器服务ACK Serverless构建和管理企业级应用。 学习完本课程后,您将能够: 掌握容器集群、容器编排的基本概念 掌握Kubernetes的基础概念及核心思想 掌握阿里云容器服务ACK/ACK Serverless概念及使用方法 基于容器服务ACK Serverless搭建和管理企业级网站应用
相关文章
|
8月前
|
Kubernetes Java 容器
如何获取k8s容器里运行的jar包
如何获取k8s容器里运行的jar包
227 0
|
2月前
|
弹性计算 Kubernetes Ubuntu
ack-kubernetes-elastic-workload,ECI这个能不能重新打个包支持下arm
ack-kubernetes-elastic-workload,ECI这个能不能重新打个包支持下arm
34 2
|
9月前
|
Kubernetes 数据管理 容器
|
9月前
|
Kubernetes 应用服务中间件 nginx
|
9月前
|
Kubernetes 算法 调度
|
9月前
|
存储 Kubernetes 安全
【K8s源码品读】010:Phase 1 - kube-scheduler - Informer是如何保存数据的
了解Informer在发现资源变化后,是怎么处理的
41 0
|
9月前
|
Kubernetes 容器
【K8s源码品读】009:Phase 1 - kube-scheduler - Informer监听资源变化
了解Informer是如何从kube-apiserver监听资源变化的情况
71 0
|
9月前
|
Kubernetes 算法 调度
|
9月前
|
存储 Kubernetes API
【K8s源码品读】007:Phase 1 - kube-apiserver - Pod数据的保存
理解Pod发送到kube-apiserver后是怎么保存的
48 0
|
9月前
|
Kubernetes API 网络架构
【K8s源码品读】006:Phase 1 - kube-apiserver - GenericAPIServer的初始化
理解kube-apiserver是中的管理核心资源的KubeAPIServer是怎么启动的
44 0