node

Documentation

Index

• Constants
• func RegToHost(node *client.HostNode, opt string)
• type Cluster
  • func CreateCluster(kubecli kubecache.KubeClient, node *client.HostNode, ...) *Cluster
  • func (n *Cluster) CacheNode(node *client.HostNode)
  • func (n *Cluster) CheckNodeInstall(node *client.HostNode)
  • func (n *Cluster) GetAllNode() (nodes []*client.HostNode)
  • func (n *Cluster) GetLabelsNode(labels map[string]string) []string
  • func (n *Cluster) GetNode(id string) *client.HostNode
  • func (n *Cluster) InstallNode()
  • func (n *Cluster) RemoveNode(nodeID string)
  • func (n *Cluster) Start(errchan chan error) error
  • func (n *Cluster) Stop(i interface{})
  • func (n *Cluster) UnlockUpdateNode(node *client.HostNode)
  • func (n *Cluster) UpdateNode(node *client.HostNode)
  • func (n *Cluster) UpdateNodeCondition(nodeID, ctype, cvalue string)

Constants

const (
	Running     = "running"
	Offline     = "offline"
	Unknown     = "unknown"
	Error       = "error"
	Init        = "init"
	InitSuccess = "init_success"
	InitFailed  = "init_failed"
	Installing  = "installing"
)

Functions

func RegToHost

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

RegToHost regist node id to hosts file

Types

type Cluster

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

Cluster node controller

func CreateCluster

func CreateCluster(kubecli kubecache.KubeClient, node *client.HostNode, datacenterConfig *config.DataCenterConfig) *Cluster

CreateCluster create node controller

func (*Cluster) CacheNode

func (n *Cluster) CacheNode(node *client.HostNode)

CacheNode 添加节点到缓存

func (*Cluster) CheckNodeInstall

func (n *Cluster) CheckNodeInstall(node *client.HostNode)

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

func (*Cluster) GetAllNode

func (n *Cluster) GetAllNode() (nodes []*client.HostNode)

GetAllNode 获取全部节点

func (*Cluster) GetLabelsNode

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

GetLabelsNode 返回匹配labels的节点ID

func (*Cluster) GetNode

func (n *Cluster) GetNode(id string) *client.HostNode

GetNode get rainbond node info

func (*Cluster) InstallNode

func (n *Cluster) InstallNode()

InstallNode 安装节点

func (*Cluster) RemoveNode

func (n *Cluster) RemoveNode(nodeID string)

RemoveNode 从缓存移除节点

func (*Cluster) Start

func (n *Cluster) Start(errchan chan error) error

Start 启动

func (*Cluster) Stop

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

Stop 停止

func (*Cluster) UnlockUpdateNode

func (n *Cluster) UnlockUpdateNode(node *client.HostNode)

UpdateNode 更新节点信息

func (*Cluster) UpdateNode

func (n *Cluster) UpdateNode(node *client.HostNode)

UpdateNode 更新节点信息

func (*Cluster) UpdateNodeCondition

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

UpdateNodeCondition 更新节点状态