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 条评论
登录 后参与评论

相关文章

来自专栏好好学习吧

ChecklistForTest

451
来自专栏CRPER折腾记

VS Code 折腾记 - (6) 基本配置/快捷键定义/代码片段的录入(snippet)

更加详细的可以阅读这里: 你可以看到when的具体范围解释,非常详细。。这里我就不一一列举出来了。。。直接在链接的文章内搜索when Clause Contex...

612
来自专栏大数据挖掘DT机器学习

PHP爬虫源码:百万级别知乎用户数据爬取与分析

代码托管地址: https://github.com/HectorHu/zhihuSpider 这次抓取了110万的用户数据,数据分析结果如下: ? 开发前...

3357
来自专栏JavaEE

jsp技术前言:一、简介:二、hello world:三、jsp语法:四、九大内置对象:总结:

我是一名Java后台学习者,但是后台程序员也需要掌握一定的前端技术。虽然说现在前端基本上是react、vue、angular三分天下,但是作为一名Java程序员...

713
来自专栏WD学习记录

html5学习笔记(一)

5. video元素允许多个source元素。source元素可以连接不同的视频文件,浏览器将会使用第一个可识别的格式

772
来自专栏晓晨的专栏

从国家统计局官网获取最新省市区三级联动数据

2144
来自专栏Android干货园

Android Studio 运行项目遇到的错误

版权声明:本文为博主原创文章,转载请标明出处。 https://blog.csdn.net/lyhhj/article/details/47...

1135
来自专栏别先生

Struts2的常见的配置文件介绍

1:package 定义一个包。 包作用,管理action。 (通常,一个业务模板用一个包)   常见属性及其说明:     (1)name  包的名字;以方便...

1839
来自专栏从零开始学自动化测试

python+requests+excel接口自动化数据驱动

一、前言 1.环境准备: - python3.6 - requests - xlrd - openpyxl - HTMLTestRunner_api 2.目前实...

1K4
来自专栏美团技术团队

Android远程调试的探索与实现

作为移动开发者,最头疼的莫过于遇到产品上线以后出现了bug,但是本地开发环境又无法复现的情况。常见的调查线上棘手问题方式大概如下: ? 以上两种方法在之前调查线...

4043

扫码关注云+社区