Documentation ¶
Index ¶
- func CreateNode(nodeID, ip string) client.HostNode
- type NodeManager
- func (n *NodeManager) AddAPIManager(apim *api.Manager) error
- func (n *NodeManager) CheckNodeHealthy() (bool, error)
- func (n *NodeManager) GetCurrentNode() *client.HostNode
- func (n *NodeManager) Start(errchan chan error) error
- func (n *NodeManager) Stop()
- func (m *NodeManager) SyncNodeStatus() error
- func (n *NodeManager) UpdateNodeStatus() error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type NodeManager ¶
NodeManager node manager
func NewNodeManager ¶
func NewNodeManager(conf *option.Conf) (*NodeManager, error)
NewNodeManager new a node manager
func (*NodeManager) AddAPIManager ¶
func (n *NodeManager) AddAPIManager(apim *api.Manager) error
AddAPIManager AddApiManager
func (*NodeManager) CheckNodeHealthy ¶
func (n *NodeManager) CheckNodeHealthy() (bool, error)
checkNodeHealthy check current node healthy. only healthy can controller other service start
func (*NodeManager) GetCurrentNode ¶
func (n *NodeManager) GetCurrentNode() *client.HostNode
GetCurrentNode get current node
func (*NodeManager) SyncNodeStatus ¶
func (m *NodeManager) SyncNodeStatus() error
func (*NodeManager) UpdateNodeStatus ¶
func (n *NodeManager) UpdateNodeStatus() error
UpdateNodeStatus UpdateNodeStatus
Click to show internal directories.
Click to hide internal directories.