public interface ClusterStore extends Store<ClusterEvent,ClusterStoreDelegate>
Modifier and Type | Method and Description |
---|---|
ControllerNode |
addNode(NodeId nodeId,
IpAddress ip,
int tcpPort)
Adds a new controller node to the cluster.
|
Instant |
getLastUpdatedInstant(NodeId nodeId)
Returns the system when the availability state was last updated.
|
ControllerNode |
getLocalNode()
Returns the local controller node.
|
ControllerNode |
getNode(NodeId nodeId)
Returns the specified controller node.
|
Set<ControllerNode> |
getNodes()
Returns the set of current cluster members.
|
ControllerNode.State |
getState(NodeId nodeId)
Returns the availability state of the specified controller node.
|
Set<Node> |
getStorageNodes()
Returns the set of storage nodes.
|
Version |
getVersion(NodeId nodeId)
Returns the version of the specified controller node.
|
void |
markFullyStarted(boolean started)
Marks the current node as fully started.
|
void |
removeNode(NodeId nodeId)
Removes the specified node from the inventory of cluster nodes.
|
hasDelegate, setDelegate, unsetDelegate
ControllerNode getLocalNode()
Set<Node> getStorageNodes()
Set<ControllerNode> getNodes()
ControllerNode getNode(NodeId nodeId)
nodeId
- controller instance identifierControllerNode.State getState(NodeId nodeId)
nodeId
- controller instance identifierVersion getVersion(NodeId nodeId)
nodeId
- controller instance identifiervoid markFullyStarted(boolean started)
started
- true indicates all components have been startedInstant getLastUpdatedInstant(NodeId nodeId)
nodeId
- controller node identifierControllerNode addNode(NodeId nodeId, IpAddress ip, int tcpPort)
nodeId
- controller node identifierip
- node IP listen addresstcpPort
- tcp listen portvoid removeNode(NodeId nodeId)
nodeId
- controller instance identifier