Kubernetes

深入理解 client-go 与 controller-runtime：从 informer 到调谐的性能之道

前言开发 Kubernetes CRD 资源时，绕不开 client-go 的 informer 机制。使用 client-go 本身并不困难——根据 kubebuilder 官网生成调谐框架，然后在 Reconcile方法中添加业务逻辑即可。然而，只停留在“能用”的层面，很难理解其中的玄妙，出了问题心里没底。有时候代码正常工作了，自己也不清楚为什么能工作（笔者遇到过好几次）。 ...

kubernetes service 原理精讲

介绍 Kubernetes Service 用于流量的负载均衡和反向代理，其通过 kube-proxy 组件实现。从服务的角度来看，kube-controller-manager 实现了服务注册，kube-proxy 实现了 kubernetes 集群内服务的负载均衡。 ...

client-go DeltaFIFO 精讲

0. 介绍 client-go list&watch 精讲介绍过 Reflector 通过 list&watch 实时获取 Kubernetes 资源的信息。并且作为生产者将资源信息存到 DeltaFIFO 中。那么消费者是在哪里定义的呢？本文围绕 DeltaFIFO 继续介绍是哪个模块消费了 DeltaFIFO 中的资源。 ...

client-go event handler 精讲

1. 介绍 client-go DeltaFIFO 介绍了从 DeltaFIFO 中取出的资源将被放到 indexer ，接着交由 processorListener 处理。本文继续看 processorListener 是如何处理 DeltaFIFO pop 的资源的。 2. 启动 handler processorListener 的启动在 sharedIndexInformer.Run() 方法定义： func (s *sharedIndexInformer) Run(stopCh <-chan struct{}) { ... // 开启协程运行 sharedIndexInformer.processor.run 方法 wg.StartWithChannel(processorStopCh, s.processor.run) ... } func (p *sharedProcessor) run(stopCh <-chan struct{}) { func() { p.listenersLock.RLock() defer p.listenersLock.RUnlock() for listener := range p.listeners { // 开启协程运行 processorListener.run p.wg.Start(listener.run) // 开启协程运行 processorListener.pop p.wg.Start(listener.pop) } p.listenersStarted = true }() <-stopCh ... } sharedProcessor.run 的重点在 processorListener.pop 和 processorListener.run，分别介绍如下。 ...

client-go indexer 精讲

1. 介绍 indexer 是 client-go 中的缓存，不同于普通缓存，indexer 是带索引的缓存。在 client-go DeltaFIFO 精讲中介绍到 DeltaFIFO 中的元素被加入到 threadSafeMap 中，这个 map 实际是 indexer 的一部分。 indexer 在 client-go 定义为接口，实现该 indexer 接口的是 cache 对象： ...

client-go list & watch 精讲

1. 介绍 client-go 架构通过 client-go 可以实现访问 kubernetes 资源的实时性，可靠性和顺序性。那么 client-go 是如何实现的呢？ 2. list & watch client-go 通过 list&watch 机制实现实时访问 kubernetes 资源，满足实时性。接下来从源码层面解析 client-go 的 list& watch 机制。 ...

client-go workqueue 精讲

1. 介绍传递到 event handler 的资源一般不会立即处理，而是先放到 workqueue 中。这是因为业务的处理速度要比资源的更新速度慢。通过 workqueue 可解耦业务的处理逻辑和资源更新逻辑。 ...

containerd 源码分析：创建 container（三）

文接 containerd 源码分析：创建 container（二）启动 task 上节介绍了创建 task，task 创建之后将返回 response 给 ctr。接着，ctr 调用 task.Start 启动容器。 1// containerd/client/task.go 2func (t *task) Start(ctx context.Context) error { 3 r, err := t.client.TaskService().Start(ctx, &tasks.StartRequest{ 4 ContainerID: t.id, 5 }) 6 if err != nil { 7 ... 8 } 9 t.pid = r.Pid 10 return nil 11} 12 13// containerd/api/services/tasks/v1/tasks_grpc.pb.go 14func (c *tasksClient) Start(ctx context.Context, in *StartRequest, opts ...grpc.CallOption) (*StartResponse, error) { 15 out := new(StartResponse) 16 err := c.cc.Invoke(ctx, "/containerd.services.tasks.v1.Tasks/Start", in, out, opts...) 17 if err != nil { 18 return nil, err 19 } 20 return out, nil 21} ctr 调用 contaienrd 的 /containerd.services.tasks.v1.Tasks/Start 接口创建 task。进入 containerd 查看提供该服务的插件： ...