flannel vxlan 工作原理分步骤详解
目录 1. 容器发包到 cni0 2. cni0 路由报文到 flannel.1 3. flannel.1 设备封包 3.1 如何已知目标 VTEP 设备的 IP 查其 mac 3.2 添加 vxlan header 3.3 把 vxlan 报文封装到 udp 报文 4. 主机网络发送 udp 报文 5. 主...
目录 1. 容器发包到 cni0 2. cni0 路由报文到 flannel.1 3. flannel.1 设备封包 3.1 如何已知目标 VTEP 设备的 IP 查其 mac 3.2 添加 vxlan header 3.3 把 vxlan 报文封装到 udp 报文 4. 主机网络发送 udp 报文 5. 主...
目录 主体流程 声明 初始化及启动 等待同步及启动 worker goroutine Reflector 工作原理 DeltaFIFO 队列 controller reflector 运行框架 之前在《关于k8s informer的基本概念与原理》中介绍...
在 Moby 代码中发现一个发布订阅设计的实现，想简单分析一下。这是一个既可以发布消息，也可以发起订阅的组件。发布者和订阅者都持有这个组件的引用，其中发布者负责发布消息，订阅者负责取消息。 组件中通过一个 map 来储存所有的发布者，以及每个发布者对消息的过滤函数。map 的 key 是一个 channel，这里要注意一下 channel 的判等操作，channel 在满足下面条件时，是相...
文章目录 go-cache 概述 实现细节 数据结构 初始化 Set/Add/Get Save（备份到文件） 总结 go-cache 概述 https://github.com/patrickmn/go-cache 是一个简单的 go 内存缓存，但是 star 数较多，可见受到大家的认可。本文主要探讨...
目录 Reader/Writer 接口 读写磁盘文件 哈希相关 检查文件是否存在 文件的硬链接 创建临时文件 json 编解码 列举目录下的所有文件 遍历目录 记录一些工具方法，避免每次都 google，当然最好是能直接看文档 Reader/Writer 接口 这两个接口是 Golang 读写操作中，最重要的两个接口，Reader 接口和 Wri...
研究一下k8s是如何处理pod的binding请求的，如何将pod与node绑定的 scheduler scheduler发起binding请求： // 构造一个binding资源 err := sched.bind(assumedPod, &v1.Binding{ // 注意Binding资源中，name是pod的name，namespace，以及uid也是pod的 ...
研究一下 K8s 测试代码是怎么写的，以https://github.com/kubernetes-sigs/sig-storage-local-static-provisioner为例。 我们有时候需要 mock 一个 Apiserver，或者 mock 一个 clientset，这时候该怎么做呢？本文稍微研究一下。 Mock clientset Discovery 的测试代码里有下面...
实现文件分片传输的一个小例子。 准备工作 找一个文件，一共42552字节。 fake@Mac iotext % ls -l file -rw-r--r-- 1 fake staff 42552 12 20 12:16 file 查看文件内容hash值。 content, err := ioutil.ReadFile(fileName) requireNoErr(err) h :=...
目录 Golang 中的 CAS 操作 实现无锁队列 相关数据结构 算法实现 参考 在并发编程中，为防止多个 goroutine 同时修改一个对象，我们一般是事先设置一把锁 sync.Mutex，要想修改对象，需要提前获取这把锁，拿不到锁就需要阻塞，直到其他 goroutine 释放锁。相对于 sync.Mutex（排它锁...
一些K8s控制组件有多个副本，如Kube-Scheduler，Kube-ControllerManager等。但同一个时刻，只有一个副本处于工作状态，其他组件处于Standby状态。这里以sig-storage-lib-external-provisioner为例研究一下选主的实现与使用。 程序的框架如下： // "k8s.io/client-go/tools/leaderelectio...
