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

相关文章

来自专栏云计算与大数据

研发:理解系统调用nice

允许进程改变它们的优先级。 包含在increment参数中的整数值用来修改进程描述符的nice字段。

1083
来自专栏我的技术专栏

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

872
来自专栏面朝大海春暖花开

properties文件乱码问题 eclipse

java最常用的开发工具eclipse里面的properties配置文件里面打开中文是乱码的,解决方式很简单。

1522
来自专栏Python小屋

Python标准库glob用法精要

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

38013
来自专栏JadePeng的技术博客

Jupyter notebook安装与使用

Jupyter Notebook(此前被称为 IPython notebook)是一个交互式笔记本,支持运行 40 多种编程语言。 安装 安装python...

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

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

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

821
来自专栏Java成神之路

Oracle_Exception_01_The Network Adapter could not establish the connection

端口号错误:一般不会错误但可能使用多个oracle版本,导致端口号为1521的情况。  修改为正确的端口号,执行下面第2步。   

852
来自专栏决胜机器学习

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

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

3485
来自专栏极客编程

node.js + mongodb 原

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

1324
来自专栏Python攻城狮

Linux命令-文件管理 1.目录方面命令:ls

Linux文件或者目录名称最长可以有265个字符,“.”代表当前目录,“..”代表上一级目录,以“.”开头的文件为隐藏文件,需要用-a参数才能显示。

862

扫码关注云+社区