Lainlet主要负责为Lain集群中各组件和app提供实时的集群状态数据。集群的实时状态由deployd组件更新到etcd中,由于这状态数据结构复杂,不利于其他组件直接读取;而且过多的组件watch etcd会对etcd造成一定的压力。
所以Lainlet的职责,就是从 etcd 中实时获取集群及应用的相关数据。简化数据结构,并提供get和watch的http api供其他组件使用。几乎每个要获取集群数据的组件,都会在Lainlet中有一个特定的api。
Lainlet内部分三层, 设计的重要目标之一是方便快捷的扩展新的数据结构API。
如图所示:
- 最下层封装了store接口,方便后端存储换成zookeeper或其他的存储,目前只实现了etcd存储。
- 中间层为watcher层,实现了通用的broadcast功能和cache数据结构,并封装成watcher接口。configWatcher和nodeWatcher等只是针对不同的key实现etcd的KV结构到cache的KV结构的转换。
- 最上层http层,通用的watch功能。同样不同的api只需定义自己的数据结构,并实现固定的接口,就可添加新的带有watch功能的api。
环境需要: go1.5+
go build -o lainlet
环境需要: etcd
./lainlet -h # 查看运行参数
# 例子
./lainlet -web :9001 -etcd 127.0.0.1:4001 -ip 127.0.0.1 -debug # 监听9001端口
-
默认情况下,api都是非watch的,就像很普通的Get请求。 如果需要需要watch功能, 可在相应api后添加
watch=1
或watch=true
参数. (watch=0
或watch=false
表示非watch) -
所有的watch请求, 都可设置heartbeat参数,表示心跳事件. 如
?heartbeat=5
表示每5秒发送一个心跳事件. 不设置或设置成0表示不使用心跳,就不会有心跳event返回 -
所有的watch请求, 返回值格式均为:
id: uint // id只有在init 和 update时候为正整数,从1开始一次递增。error和heartbeat event id均为0 event: string // "init", "update", "delete", "error"或 "heartbeat" data: string // heartbeat event没有此项, error event的data为错误说明
而对于Get请求, 返回值是watch请求的data部分.
返回/lain/config/<target>
的值, 接收参数target, 如果不指定,则返回所有的配置值。格式为json
target 会被作为所有配置项的前缀进行搜索,比如 target=a
的情况会把所有 a
开头的配置项都返回。
返回/lain/config/pod_group/<appname>
的精简结构
返回/lain/deployd/core_info/<appname>
的值, 可接受参数appname
, 如果不给定appname,则返回所有app的coreinfo信息
返回跑在指定ip上的所有的proc的name列表. 可接收参数nodeip
, 如果不给定nodeip
,则使用lainlet的本机
专给proxy用的api, podgroup的一个精简版本
返回 /lain/deployd/depends/pods
下的数据的简化版本
target
参数如果不指定,返回所有 depends 数据,如果指定,它则作为前缀匹配所有 depends,返回一部分。
返回 /lain/nodes/nodes
下的数据的简化版本
返回 某节点下所有container的信息列表
返回所有web类型的proc的信息,数据结构和coreinfo类似,但是只包含container IP, Expose和Annotation信息。
为了保证在集群异常时,webrouter 的已有配置不被删除,在调用该接口时,如果超过一半的容器没有 IP 或者没有任何容器信息,则会返回 error。
返回所有本地的proc的信息,数据结构和coreinfo类似,但是只包含Annotation和InstanceNo信息
返回lainlet的debug信息
返回lainlet的版本信息
- 如果lain集群的node数增加到100+,每个node上一个lainlet, 每个lainletwatch etcd的连接数大约10个左右。 这样整个etcd集群就是承受1000+的watch连接,etcd集群是无法承受这个数量级连接的。
Lainlet is released under the MIT license.