k8s源码分析-----kubelet(9)podWorkers

说明:此文章为腾讯云机器自动从本人csdn博客搬迁过来。是本人授权操作。

申明:无本人授权,不可转载本文。如有转载,本人保留追究其法律责任的权利。

龚浩华,QQ 29185807,月牙寂 道长

第一时间获取文章,可以关注本人公众号 月牙寂道长 yueyajidaozhang

源码为k8s v1.1.1稳定版本

3.3 podworkers

在3.2(也就是在k8s源码分析-----kubelet(8)pod管理)末尾,我们看到了,最终的处理都进入了podworkers中。

现在我们就来分析下podworkers

1、构建

代码在k8s.io\kubernetes\pkg\kubelet\kubelet.go中

// New creates a new Kubelet for use in main

func NewMainKubelet(

我们先看看其中的参数runtimeCache

代码在k8s.io\kubernetes\pkg\kubelet\container\runtime_cache.go中

从上图可以看出主要提供了两个接口函数GetPods和ForceUpdateIfOlder。在NewRuntimeCache的时候,提供的getter则是containerRuntime(这个之前的文章已经分析过)

结构体很简单

下面我们看看Getpods

从函数的注释就能够看的出来,其实runtimecache保存的就是当前pod的一个缓存,如果换成没有过期的话,则返回,如果过期了则重新更新

我们再看看

从上面的三个函数中我们就看到了getter.GetPods(其实这个就是containerRuntime)

现在看看podworkers

上面有很多的成员,其中最重要的就是podupdates,这个是针对不同的uid pod开启了一个通信管道。

2、工作

我们先看看kubelet的dispatchWork

其中就调用了podworks的Updatepod

我们继续跟踪

这一部分代码,其实就是对新的uid pod开启来一个chan 管道,真正的运行是在managePodLoop,稍后我们对其分析

isworking防止同一个pod重入。然后新的pod则将信息发送到管道。真的运行是在managePodLoop

我们再看下managePodLoop

这是一个死循环的,消费者,前面的updatepod是生产者,负责将pod通过管道发送到这个消费者。先从runtimecache中获取到pods,然后将调用syncpodFn(这个参数是在构建podworkers传入的,其实就是kubelet的syncPod),稍后在分析syncpod

这个消费者什么时候死亡呢?

我们看下面,下面的ForgetWorker和ForgetNonExistingPodWorkers。调用了removeworker,在这个函数中,关闭了管道,那么消费者也将随之消失

那么我们即将进入最后的步骤func (kl *Kubelet) syncPod

上面的是一个函数返回时的操作

上面中,开始真正的动作。killpod,当pod无法运行的时候

然后开始解析,挂载volume

等等一系列的操作完之后,调用了containerRuntime.synpod

这个就是我们之前分析的对docker封装的一个containerRuntime。

4、总结

关于kubelet的所有分析都完成了。这一系列的文章只是对kubelet做了一个简单的分析,其中还有很多部分并没有完全的分析,不过我相信经过这些分析之后,对kubelet的主要工作应该已经有了一个大致的了解。

再说手kubelet的设计,这里面用的最多的是生产者和消费者模型,都是通过chan来进行通信,这个也是golang官方极力推荐的模式。再有就是,模块独立化,各个模块自我管理,这个与我在15年上海golang大会上所提到的AOP(Agent Oriented Programmig 面向智能体编程)的理念是一样的。

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

编辑于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏数据和云

数据库选型:多核还是多线程?

数据库选型,是用多核主机还是多线程主机?我是否可以用比较便宜的单核超线程(Hyper-Threading,HT)的机器,来替代双核非HT的机器? 回答这个问题,...

3127
来自专栏纯洁的微笑

本周新鲜事:开源那些事

732
来自专栏程序你好

MySQL 8支持文档存储,并带来性能和安全方面的改进

691
来自专栏美码师

完美数据迁移-MongoDB Stream的应用

最近微服务架构火的不行,但本质上也只是风口上的一个热点词汇。 作为笔者的经验来说,想要应用一个新的架构需要带来的变革成本是非常高的。

772
来自专栏IT大咖说

知数堂联合创始人叶金荣:MySQL 5.7新时代

摘要 MySQL 5.7版本新增了很多特别实用的功能,截止目前已经发布5.7.17版本,也越来越成熟了,而且Group Replication也GA了。就让我们...

3566
来自专栏微服务生态

Faas,又一个未来?

云计算时代出现了大量XaaS形式的概念,从IaaS、PaaS、SaaS到容器云引领的CaaS,再到火热的微服务架构,以及现在越来越多被谈起的Serverless...

724
来自专栏沃趣科技

基于Oracle的私有云架构探析(连载三)@【DTCC干货分享】

• 启用Instance Caging Instance Caging 通过设置2个数据库的初始化参数来达到管控CPU的目的: • cpu_count ...

3365
来自专栏散尽浮华

Linux系统下CPU使用(load average)梳理

在平时的运维工作中,当一台服务器的性能出现问题时,通常会去看当前的CPU使用情况,尤其是看下CPU的负载情况(load average)。对一般的系统来说,根据...

2976
来自专栏坚毅的PHP

node.js进阶学习

简介 如果您听说过 Node,或者阅读过一些文章,宣称 Node 是多么多么的棒,那么您可能会想:“Node 究竟是什么东西?”尽管不是针对所有人的,但 Nod...

3867
来自专栏杨建荣的学习笔记

一个清理和查询都要兼顾的简单方案(r7笔记第68天)

最近和开发应用的同学在讨论一个需求,目前他们碰到了一些性能问题,想让我来看看是否能够从数据库的角度有一些解决方案。 假设表为消费记录,简称service_det...

3214

扫描关注云+社区