swarm源码分析(3)---manage cluster

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

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

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

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

1、构建流程

我们先看看cluster的构建。

代码在swarm\manage.go

初始化了一个cluster对象

更新nodes

另外在scheduler和api server中也都传进去了cluster对象。

说明cluster的重要

2、cluster

代码在swarm\cluster\cluster.go

先看结构体

里面最重要的两个东西

1、store,这个前面一篇文章已经分析过了

2、nodes,这个用于保存集群中的节点信息,并与节点进行连通的部分

看下NewCluster函数

下面我们看看cluster提供的一些接口

UpdateNodes

这是一个重要的接口,用于与discovery对接,用于node的更新

将传入的node,进行遍历,连接(Connect),并添加(AddNode)

AddNode

添加node,通过map存储信息,来判断是否重复添加。功能很简单

Events

用于设置eventhandler。在构建流程汇总,设置了一个loghandler

DeployContainer

部署一个Container

通过node进行create一个Container,创建成功后,将信息保存包store中。

DestroyContainer

销毁一个Container。

从node中销毁Container,成功后,也将其信息从store中删除。

小结

cluster的功能简单,就是属于一个简单地管理功能。具体的操作还是在node中。

3、Node

我们先看看结构体

代码在swarm\cluster\node.go

其中一些比较关键的东西有

containers:用于记录当前node上部署的containers

images:用于记录当前node上的镜像信息

client:这个是关键,用于与node连接的接口

下面我们看看container结构体

代码在swarm\cluster\container.go

下面看看node的一些操作

NewNode

创建node

都是一些基本参数的初始化

Connect

在构建完node之后,就会调用Connect对node进行连接

上面代码中构建了一个dockerclient,用于与node连接

对于上面代码中的流程,下面我们一个一个的进行分析

updateSpecs

其实这里才是对node结构体里面的成员进行初始化的地方。

获取到了id,name,cpus等等信息,将其初始化到node结构体中

RefreshContainers

更新node上的container信息。

通过dockerclient获取到container list信息。

updateContainer

在上面的RefreshContainers,只是获取到了container list,真正进行更新的是在updateContainer这个函数中

获取到Container信息后,判断是否已经有记录。

没有记录的则要重新调用dockerclient.InspectContainer获取Container信息。

refreshImages

用于更新images信息。

调用dockerclient,获取images list,并进行更新

refreshLoop

这个是死循环。

有两个chan信号

1、Container信息更新同步信号。下图是信号来源

2、强制超时Container信息更新同步信号,下图是超时时间

继续refresh loop

如果出错,则刷新images。

如果还是出错,则判断node disconnet,打印日志。

如果没有err,则判断是否healthy,如果不是,则要进行重连操作。先调用StopAllMonitorEvents,再调用StartMonitorEvents

handler

下面我们看看handler。这个很关键。这里提供了关于一些操作的接口。用于dockerclient的回调。具体还得需要看看dockerclient源码

4、dockerclient

代码在github.com\samalba\dockerclient\dockerclient.go

先看看结构体

从上面一看就知道,其是对httpclient的一个封装

NewDockerClient

构建了docketclient结构体,其最主要的还是构建httpclient

StartMonitorEvents

我们先来看看这个函数是干嘛用的

这里有一个标志位。然后调用了getEvents

这里像node发起了events的get请求,用于获取event。通过解码,获取event信息,然后调用node传入dockerclient中的handler来进行事件回调处理。

StopAllMonitorEvents

仅仅是设置了一个标志位

ListImages

通过像node发起get请求,获取images信息,然后解码返回

CreateContainer

把Container信息经过json编码,然后通过post请求发送到node上

小结

dockerclient还提供了很多的接口,基本上都是通过构建http请求,来与node进行通信。就不一一的去贴代码了。下图是docketclient提供的操作

文中如果有哪里讲解的不对的地方,还请见谅,望指正。

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

编辑于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏流浪猫的golang

go test 使用全教程

golang 中的go test 为golang 软件包提供了一种单元测试方式,非常简单的同时也非常好用。 ok 先来看看怎么用? 1. 新建go 文件...

944
来自专栏Python小屋

Python标准库glob用法精要

Python标准库glob提供了glob()和iglob()两个函数用来枚举指定文件夹中符合特定模式的文件列表,支持“?”和“*”通配符。 >>> impor...

42013
来自专栏决胜机器学习

《Redis设计与实现》读书笔记(十五) ——Redis AOF持久化原理与实现

《Redis设计与实现》读书笔记(十五) ——Redis AOF持久化原理与实现 (原创内容,转载请注明来源,谢谢) 一、概述 AOF(Append OnFil...

3585
来自专栏我的技术专栏

vi 方向键和Backspace键失效问题的解决方法

982
来自专栏pangguoming

angular之interceptors拦截器

<!DOCTYPE html> <html ng-app="nickApp"> <head> <meta charset="UTF-8"> <m...

4075
来自专栏云计算教程系列

在Linux中使用find命令行查找文件

find是一个基于条件机制递归过滤文件系统中对象的命令。使用find搜索文件系统中的文件或目录。使用-exec标志,可以在同一命令中找到并立即处理文件。

1242
来自专栏极客编程

node.js + mongodb 原

想写博客很长时间了,因为一直身患懒癌,所以一直拖到了现在。markdown的语法也是刚刚学,试验一下效果 好了不说了,直接上干货了。 -------------...

1544
来自专栏HaHack

化繁为简的企业级 Git 管理实践(一):多分支子模块依赖管理

1612
来自专栏云计算教程系列

如何使用RVM在FreeBSD 10.1上安装Ruby on Rails

Ruby on Rails,简称RoR,是一个用Ruby编写的非常流行的全栈Web应用程序开发框架。它允许您快速开发符合MVC(模型 - 视图 - 控制器)模式...

1151
来自专栏不想当开发的产品不是好测试

Git 默认不区分大小写

背景: 通过代码规范,修改了包名为全小写(修改了文件夹目录),但发现push后,git服务器的文件夹目录还是为大写 解决方法: git默认是不区分大小写的,意思...

21310

扫码关注云+社区

领取腾讯云代金券