public class MetaStoreService extends Object implements StoreService<MetaNode>
| 构造器和说明 |
|---|
MetaStoreService() |
| 限定符和类型 | 方法和说明 |
|---|---|
NodeChangeResult |
addNode(MetaNode metaNode)
add new node,when renew request not found node will be add again
|
void |
confirmNodeStatus(String connectId,
String ip)
node change info push must be confirm received,
|
DataCenterNodes |
getDataCenterNodes()
get DataCenter Nodes list contains version
|
Collection<MetaNode> |
getExpired()
get expired node list
|
NodeChangeResult |
getNodeChangeResult()
get node info request
|
Map<String,MetaNode> |
getNodes()
get all Nodes from all dataCenter
|
Node.NodeType |
getNodeType()
get node type
|
void |
getOtherDataCenterNodeAndUpdate()
schedule check other dataCenter node change and update
|
void |
pushNodeListChange()
push node change result
|
boolean |
removeNode(String ipAddress)
remove current dataCenter dataNode by ipAddress
|
void |
removeNodes(Collection<MetaNode> nodes)
remove current dataCenter dataNodes
|
void |
reNew(MetaNode node,
int duration)
heartbeat update node expired time
|
NodeChangeResult |
setNodes(List<MetaNode> metaNodes) |
void |
updateOtherDataCenterNodes(DataCenterNodes<MetaNode> dataCenterNodes)
get other meta server node change update version and node info,and push current dataCenter node change info
|
public Node.NodeType getNodeType()
StoreServicegetNodeType 在接口中 StoreService<MetaNode>public NodeChangeResult setNodes(List<MetaNode> metaNodes)
setNodes 在接口中 StoreService<MetaNode>public NodeChangeResult addNode(MetaNode metaNode)
StoreServiceaddNode 在接口中 StoreService<MetaNode>public boolean removeNode(String ipAddress)
StoreServiceremoveNode 在接口中 StoreService<MetaNode>public void removeNodes(Collection<MetaNode> nodes)
StoreServiceremoveNodes 在接口中 StoreService<MetaNode>public void confirmNodeStatus(String connectId, String ip)
StoreServiceconfirmNodeStatus 在接口中 StoreService<MetaNode>connectId - received Node ipAddressip - will be confirmed node ippublic void reNew(MetaNode node, int duration)
StoreServicereNew 在接口中 StoreService<MetaNode>public Collection<MetaNode> getExpired()
StoreServicegetExpired 在接口中 StoreService<MetaNode>public Map<String,MetaNode> getNodes()
StoreServicegetNodes 在接口中 StoreService<MetaNode>public NodeChangeResult getNodeChangeResult()
StoreServicegetNodeChangeResult 在接口中 StoreService<MetaNode>public void getOtherDataCenterNodeAndUpdate()
StoreServicegetOtherDataCenterNodeAndUpdate 在接口中 StoreService<MetaNode>public void updateOtherDataCenterNodes(DataCenterNodes<MetaNode> dataCenterNodes)
StoreServiceupdateOtherDataCenterNodes 在接口中 StoreService<MetaNode>public DataCenterNodes getDataCenterNodes()
StoreServicegetDataCenterNodes 在接口中 StoreService<MetaNode>public void pushNodeListChange()
StoreServicepushNodeListChange 在接口中 StoreService<MetaNode>Copyright © 2019 The Ant Financial. All rights reserved.