皮皮网

1.深入理解k8s -- workqueue
2.Kubernetes —— Pod 自动水平伸缩源码剖析（上）
3.原译 | 对话《魔兽》**导演：邓肯琼斯与游戏及魔兽的源码不解之缘
4.Client-go源码之ListerWatcher接口
5.NodeController 源码分析

深入理解k8s -- workqueue

       深入理解k8s -- workqueue

       在探讨k8s中的informer组件时，workqueue是源码一个关键角色。在前文的源码Controller源码分析中，workqueue的源码使用已经有所提及。工作队列是源码k8s中用于处理资源变更事件和调度任务的高效机制。它支持三种类型的源码腾讯会员抽奖网站源码队列：简单的FIFO队列、延时队列以及限速队列。源码

       工作队列通过一个名为Type的源码底层数据结构来实现，它实现了workqueue.Interface接口。源码Type结构体包含queue、源码dirty和processing三个重要字段，源码以及一个golang原生的源码条件锁cond。queue用于存储待处理的源码任务，dirty和processing用于管理任务的源码添加和完成状态。cond用于控制多个协程的源码同步操作。

       接下来，我们通过源码深入Type的方法实现，如Add、Get和Done。Add方法简单地将任务添加到queue、dirty和processing中。Get方法包含删除逻辑，同时会检查dirty中是否已有数据，若无，则从queue中取出任务。微赞的源码Done方法用于清理processing状态，确保任务正确处理并移出队列。Get和Done方法之间的配合保证了任务的正确执行和管理。

       在处理资源变更事件时，工作队列的作用尤为明显。在事件触发后，队列将资源变更事件加入到队列中，由Controller进行处理。Controller通过工作队列的Get方法获取待处理的任务，执行处理逻辑，然后调用Done方法将任务标记为完成。这种机制保证了资源变更事件能够被及时且有序地处理。

       除了基础的FIFO队列，k8s还提供了更高级的队列类型，如延时队列和限速队列。延时队列允许用户指定任务的延迟时间，即在特定时间后才将任务加入队列。这有助于优化资源的处理顺序和负载均衡。限速队列则进一步增强了队列功能，通过限速器动态调整任务的处理速率，避免系统过载或资源浪费。

       限速队列基于延时队列实现，通过引入限速器来控制任务的处理速率。常见的源码去版权方法限速器包括BucketRateLimiter、ItemExponentialFailureRateLimiter、ItemFastSlowRateLimiter和MaxOfRateLimiter。这些限速器可以根据不同需求灵活配置，实现资源的高效管理和优化。

       总结而言，工作队列是k8s中实现资源变更事件处理和任务调度的核心组件，通过简单、延时和限速队列的不同组合，可以满足各种复杂场景的需求，实现资源管理的高效、有序和灵活。

Kubernetes —— Pod 自动水平伸缩源码剖析（上）

       ReplicaSet 控制器负责维持指定数量的 Pod 实例正常运行，这个数量通常由声明的工作负载资源对象如 Deployment 中的.spec.replicas字段定义。手动伸缩适用于对应用程序进行预调整，如在电商促销活动前对应用进行扩容，活动结束后缩容。然而，这种方式不适合动态变化的应用负载。

       Kubernetes 提供了 Pod 自动水平伸缩（HorizontalPodAutoscaler，简称HPA）能力，允许定义动态应用容量，容量可根据负载情况变化。例如，当 Pod 的顶部滑动导航源码平均 CPU 使用率达到 %，且最大 Pod 运行数不超过 个时，HPA 会触发水平扩展。

       HPA 控制器负责维持资源状态与期望状态一致，即使出现错误也会继续处理，直至状态一致，称为调协。控制器依赖 MetricsClient 获取监控数据，包括 Pod 的 CPU 和内存使用情况等。

       MetricsClient 接口定义了获取不同度量指标类别的监控数据的能力。实现 MetricsClient 的客户端分别用于集成 API 组 metrics.k8s.io，处理集群内置度量指标，自定义度量指标和集群外部度量指标。

       HPA 控制器创建并运行，依赖 Scale 对象客户端、HorizontalPodAutoscalersGetter、Metrics 客户端、HPA Informer 和 Pod Informer 等组件。Pod 副本数计算器根据度量指标监控数据和 HPA 的理想资源使用率，决策 Pod 副本容量的伸缩。

       此篇介绍了 HPA 的基本概念和相关组件的创建过程，后续文章将深入探讨 HPA 控制器的调协逻辑。感谢阅读，欢迎指正。

原译 | 对话《魔兽》**导演：邓肯琼斯与游戏及魔兽的汉末王者源码不解之缘

       邓肯琼斯，英国摇滚巨星大卫鲍伊之子，也是**《源代码》、《月球》的导演，执导的《魔兽》**即将上映。在他的生活中，游戏扮演着怎样的角色呢？最近，邓肯琼斯接受了Game Informer的采访，分享了他的游戏经历以及对《魔兽》**的见解。以下是手游那点事对采访内容的编译。

       Game Informer：欢迎邓肯琼斯参与我们的节目，我们很少邀请**导演来。

       邓肯琼斯：我从小就是游戏迷，希望未来能看到更多喜欢游戏的导演加入。

       《魔兽》**拍摄繁忙，您还有时间玩游戏吗？

       我的大部分闲暇时间都花在了玩《幽浮2》上。我在游戏中将惹我不快的剧组成员形象化为游戏角色，作为我的防御工具，而我喜欢的伙伴则扮演狙击手。

       您心目中最佳游戏是？

       在我心中，有三款游戏并列第一。《辛迪加战争》是Bullfrog开发的一款策略游戏，玩家需要在上帝视角下操作四个单位在城市中行动，可以升级武器、科技以对抗敌人、完成任务。《卫星统治》是一款去年末推出的佳作，确实抓住了《辛迪加战争》的灵魂。

       您对《卫星统治》的评价如何？

       我知道并购买了这款游戏，它确实继承了《辛迪加战争》的精髓。

       您对游戏有多热衷？

       我是一个重度玩家，对《辛迪加战争》情有独钟。我也喜欢《Speedball 2: Brutal Deluxe》，尤其偏爱Amiga版本。这款游戏具有独特的未来运动风格，充满了暴力与冲突，玩家需要操作队伍进攻对手的球门。

       除了上述游戏，您还钟爱《创世纪III：出埃及记》。这款游戏对我作为游戏宅的身份有着证明作用。

       《月球》**备受好评，但票房表现不佳。您对此有何感想？

       大家都很喜欢这部**，但遗憾的是票房成绩并不理想。对于在任天堂NDS上发布同名游戏的《月球》，您有何看法？

       虽然可能会引起混淆，但对我而言，游戏和**都是独特的艺术形式，各自拥有独特的受众。

       您是如何与《魔兽》**结缘的？

       我从《创世纪Online》开始，作为公会会长参与游戏，对《魔兽世界》产生了浓厚的兴趣。虽然我主要关注即时战略游戏，如《魔兽争霸》和《命令与征服》，但《魔兽》**的制作过程充满了与《魔兽争霸》铁杆粉丝的合作。

       您对魔兽世界观的呈现有何期待？

       **将从《魔兽争霸》初代故事出发，我们期待在**中埋下与游戏相关的彩蛋，同时也致力于讲述一个吸引人的故事，让游戏内外的观众都能享受观影体验。

       《魔兽》**的未来如何？

       **的成败取决于首映后的反响，如果反响良好，我们有望考虑拍摄续集。执导这样的**是一场考验，但同时也是一次充满挑战与满足感的体验。

Client-go源码之ListerWatcher接口

       ListerWatcher接口将Lister和Watcher接口融合，前者负责与APIServer通信以获取全量对象，后者负责监控对象的增量变化。List-Watch机制旨在提升访问效率，避免过多客户端频繁获取全量资源信息，减轻APIServer负载。通过本地缓存和监听变化，仅需一次获取全量对象并同步本地缓存，后续监听变化同步缓存即可，大幅优化与APIServer通信效率。

       接口定义明确，ListerWatcher包含List和Watch两个核心函数，分别用于获取全量对象和监听对象变化。具体实现中，ListerWatcher通过调用ListFunc和WatchFunc来分别执行List和Watch操作。各资源类型Informer通过注册自己的ListWatch结构，实现在创建时自动调用特定的List和Watch函数，如Deployment的Informer，利用其资源类型对应的ClientSet初始化ListWatch，并仅返回该类型对象。

NodeController 源码分析

       本文主要分析NodeLifecycleController在Kubernetes v1.版本中的功能及其源码实现。NodeLifecycleController主要负责定期监控节点状态，根据节点的condition添加相应的taint标签或直接驱逐节点上的Pod。

       在解释NodeLifecycleController功能之前，先了解一下taint的作用。在NodeLifecycleController中，taint的使用效果体现在节点的taint上，影响着Pod在节点上的调度。

       NodeLifecycleController利用多个feature-gates进行功能扩展。在源码分析部分，我们以Kubernetes v1.版本为例，深入研究了启动方法、初始化流程、监听对象以及核心逻辑。

       启动方法startNodeLifecycleController首先调用lifecyclecontroller.NewNodeLifecycleController进行初始化，并传入组件参数及两个feature-gates：TaintBasedEvictions和TaintNodesByCondition。随后调用lifecycleController.Run启动控制循环，监听包括lease、pods、nodes、daemonSets在内的四种对象。

       在初始化过程中，多个默认参数被设定，如--enable-taint-manager等。NewNodeLifecycleController方法详细展示了NodeLifecycleController的结构和核心逻辑，包括taintManager和NodeLifecycleController的监听和处理机制。

       Run方法是启动方法，它启动多个goroutine执行controller功能，关键逻辑包括调用多个方法来完成核心功能。

       当组件启动时，若--enable-taint-manager参数为true，taintManager将启用，确保当节点上的Pod不兼容节点taint时，会将Pod驱逐。反之，已调度至该节点的Pod将保持存在，新创建的Pod需兼容节点taint以调度至该节点。

       tc.worker处理来自channel的数据，优先处理nodeUpdateChannels中的数据。tc.handleNodeUpdate和tc.handlePodUpdate分别处理节点更新和Pod更新，最终调用tc.processPodOnNode检查Pod是否兼容节点的taints。

       NodeLifecycleController中的nodeInformer监听节点变化，nc.doNodeProcessingPassWorker添加合适的NoSchedule taint和标签。当启用了TaintBasedEvictions特性，nc.doNoExecuteTaintingPass处理节点并根据NodeCondition添加taint，以驱逐Pod。未启用该特性时，nc.doEvictionPass将直接驱逐节点上的Pod。

       nc.monitorNodeHealth持续监控节点状态，更新节点taint或驱逐Pod，并为集群中的所有节点划分zoneStates以设置驱逐速率。nc.tryUpdateNodeHealth更新节点状态数据，判断节点是否已进入未知状态。

       本文综上所述，深入剖析了NodeLifecycleController的功能、实现机制以及关键逻辑，为理解和优化Kubernetes集群提供了参考。