Method checkNodesForever

controller/controller.go:54–65

checkNodesForever 持续运行检查节点函数，并维护节点数组

()

//checkNodesForever 持续运行检查节点函数，并维护节点数组
func (c *Controller) checkNodesForever() {
	for {
		now := time.Now()
		for ip, node := range c.nodePool.Nodes {
			if now.Sub(node.Update) > time.Duration(time.Second*10) {
				delete(c.nodePool.Nodes, ip)
				lg.Warn("Inspector %v, %v lost from controller", ip, node.Hostname)
			}
		}
		time.Sleep(time.Second * 5)
	}
}

//receiveHearbeat 接收心跳包，并更新节点状态
func (c *Controller) receiveHearbeat(heartbeat *types.HeartBeat) {