Documentation ¶
Index ¶
- Constants
- type Manager
- func (manager *Manager) AddAgentAcceptor(agent types.Node)
- func (manager *Manager) AddNode(node types.Node) error
- func (manager *Manager) AddRaftNode(swanNode types.Node) error
- func (manager *Manager) GetManagers() []types.Node
- func (manager *Manager) GetNode(nodeID string) (types.Node, error)
- func (manager *Manager) GetNodes() []types.Node
- func (manager *Manager) InitAndStart(ctx context.Context) error
- func (manager *Manager) JoinAndStart(ctx context.Context) error
- func (manager *Manager) JoinToCluster(nodeInfo types.Node) ([]types.Node, error)
- func (manager *Manager) LoadNodeData() error
- func (manager *Manager) RemoveAgentAcceptor(agentID string)
- func (manager *Manager) RemoveNode(node types.Node) error
- func (manager *Manager) SendAgentInitData(agent types.Node)
- func (manager *Manager) Stop()
- type ManagerApi
- func (api *ManagerApi) AddNode(request *restful.Request, response *restful.Response)
- func (api *ManagerApi) GetNodes(request *restful.Request, response *restful.Response)
- func (api *ManagerApi) Register(container *restful.Container)
- func (api *ManagerApi) RemoveNode(request *restful.Request, response *restful.Response)
- func (api *ManagerApi) StopNode(request *restful.Request, response *restful.Response)
Constants ¶
View Source
const JoinRetryInterval = 5
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Manager ¶
type Manager struct { CancelFunc context.CancelFunc NodeInfo types.Node JoinAddrs []string // contains filtered or unexported fields }
func (*Manager) AddAgentAcceptor ¶
func (*Manager) AddRaftNode ¶ added in v0.1.3
func (*Manager) GetManagers ¶ added in v0.1.7
func (*Manager) InitAndStart ¶ added in v0.1.7
func (*Manager) JoinAndStart ¶ added in v0.1.7
func (*Manager) JoinToCluster ¶ added in v0.1.7
func (*Manager) LoadNodeData ¶ added in v0.1.3
func (*Manager) RemoveAgentAcceptor ¶ added in v0.1.3
func (*Manager) RemoveNode ¶ added in v0.1.3
func (*Manager) SendAgentInitData ¶
type ManagerApi ¶
type ManagerApi struct {
// contains filtered or unexported fields
}
func (*ManagerApi) AddNode ¶ added in v0.1.7
func (api *ManagerApi) AddNode(request *restful.Request, response *restful.Response)
func (*ManagerApi) GetNodes ¶ added in v0.1.7
func (api *ManagerApi) GetNodes(request *restful.Request, response *restful.Response)
func (*ManagerApi) Register ¶
func (api *ManagerApi) Register(container *restful.Container)
func (*ManagerApi) RemoveNode ¶ added in v0.1.7
func (api *ManagerApi) RemoveNode(request *restful.Request, response *restful.Response)
Click to show internal directories.
Click to hide internal directories.