public interface ClusterAdminService extends ClusterService
Modifier and Type | Method and Description |
---|---|
ControllerNode |
addNode(NodeId nodeId,
IpAddress ip,
int tcpPort)
Adds a new controller node to the cluster.
|
void |
formCluster(java.util.Set<ControllerNode> nodes)
Forms cluster configuration based on the specified set of node
information. This method resets and restarts the controller
instance.
|
void |
formCluster(java.util.Set<ControllerNode> nodes,
int partitionSize)
Forms cluster configuration based on the specified set of node
information. This method resets and restarts the controller
instance.
|
void |
markFullyStarted(boolean started)
Marks the current node as fully started or not.
|
void |
removeNode(NodeId nodeId)
Removes the specified node from the cluster node list.
|
getLastUpdated, getLastUpdatedInstant, getLocalNode, getNode, getNodes, getState, getVersion
addListener, removeListener
void formCluster(java.util.Set<ControllerNode> nodes)
nodes
- set of nodes that form the clustervoid formCluster(java.util.Set<ControllerNode> nodes, int partitionSize)
nodes
- set of nodes that form the clusterpartitionSize
- number of nodes to compose a partitionControllerNode addNode(NodeId nodeId, IpAddress ip, int tcpPort)
nodeId
- controller node identifierip
- node IP listen addresstcpPort
- tcp listen portvoid removeNode(NodeId nodeId)
nodeId
- controller node identifiervoid markFullyStarted(boolean started)
started
- true indicates all components have been started