node

Documentation

Overview

当前包处理集群节点的管理

Index

• func RegToHost(node *model.HostNode, opt string)
• type NodeCluster
  • func CreateNodeCluster(k8sClient *kubernetes.Clientset, node *model.HostNode, ...) *NodeCluster
  • func (n *NodeCluster) CacheNode(node *model.HostNode)
  • func (n *NodeCluster) CheckNodeInstall(node *model.HostNode)
  • func (n *NodeCluster) GetAllNode() (nodes []*model.HostNode)
  • func (n *NodeCluster) GetLabelsNode(labels map[string]string) []string
  • func (n *NodeCluster) GetNode(id string) *model.HostNode
  • func (n *NodeCluster) InstallNode()
  • func (n *NodeCluster) RemoveNode(node *model.HostNode)
  • func (n *NodeCluster) Start() error
  • func (n *NodeCluster) Stop(i interface{})
  • func (n *NodeCluster) UpdateNode(node *model.HostNode)
  • func (n *NodeCluster) UpdateNodeCondition(nodeID, ctype, cvalue string)

Functions

func RegToHost

func RegToHost(node *model.HostNode, opt string)

RegToHost 注册节点

Types

type NodeCluster

type NodeCluster struct {
	// contains filtered or unexported fields
}

NodeCluster 节点管理器

func CreateNodeCluster

func CreateNodeCluster(k8sClient *kubernetes.Clientset, node *model.HostNode, datacenterConfig *config.DataCenterConfig) *NodeCluster

CreateNodeCluster 创建节点管理器

func (*NodeCluster) CacheNode

func (n *NodeCluster) CacheNode(node *model.HostNode)

CacheNode 添加节点到缓存

func (*NodeCluster) CheckNodeInstall

func (n *NodeCluster) CheckNodeInstall(node *model.HostNode)

CheckNodeInstall 简称节点是否安装 rainbond node 如果未安装，尝试安装

func (*NodeCluster) GetAllNode

func (n *NodeCluster) GetAllNode() (nodes []*model.HostNode)

GetAllNode 获取全部节点

func (*NodeCluster) GetLabelsNode

func (n *NodeCluster) GetLabelsNode(labels map[string]string) []string

GetLabelsNode 返回匹配labels的节点ID

func (*NodeCluster) GetNode

func (n *NodeCluster) GetNode(id string) *model.HostNode

GetNode 从缓存获取节点信息

func (*NodeCluster) InstallNode

func (n *NodeCluster) InstallNode()

InstallNode 安装节点

func (*NodeCluster) RemoveNode

func (n *NodeCluster) RemoveNode(node *model.HostNode)

RemoveNode 从缓存移除节点

func (*NodeCluster) Start

func (n *NodeCluster) Start() error

Start 启动

func (*NodeCluster) Stop

func (n *NodeCluster) Stop(i interface{})

Stop 停止

func (*NodeCluster) UpdateNode

func (n *NodeCluster) UpdateNode(node *model.HostNode)

UpdateNode 更新节点信息

func (*NodeCluster) UpdateNodeCondition

func (n *NodeCluster) UpdateNodeCondition(nodeID, ctype, cvalue string)

UpdateNodeCondition 更新节点状态