public class SessionStoreService extends Object implements StoreService<SessionNode>
| 构造器和说明 |
|---|
SessionStoreService() |
| 限定符和类型 | 方法和说明 |
|---|---|
NodeChangeResult |
addNode(SessionNode sessionNode)
add new node,when renew request not found node will be add again
|
void |
confirmNodeStatus(String ipAddress,
String confirmNodeIp)
node change info push must be confirm received,
|
DataCenterNodes |
getDataCenterNodes()
get DataCenter Nodes list contains version
|
Collection<SessionNode> |
getExpired()
get expired node list
|
NodeChangeResult |
getNodeChangeResult()
get node info request
|
Map<String,SessionNode> |
getNodes()
get all Nodes from all dataCenter
|
Node.NodeType |
getNodeType()
get node type
|
void |
getOtherDataCenterNodeAndUpdate()
schedule check other dataCenter node change and update
|
NodeConfirmStatusService<SessionNode> |
getSessionConfirmStatusService()
Getter method for property sessionConfirmStatusService.
|
void |
pushNodeListChange()
push node change result
|
boolean |
removeNode(String ipAddress)
remove current dataCenter dataNode by ipAddress
|
void |
removeNodes(Collection<SessionNode> nodes)
remove current dataCenter dataNodes
|
void |
reNew(SessionNode sessionNode,
int duration)
heartbeat update node expired time
|
void |
setDataStoreService(StoreService dataStoreService)
Setter method for property dataStoreService.
|
void |
setNodeConfig(NodeConfig nodeConfig)
Setter method for property nodeConfig.
|
NodeChangeResult |
setNodes(List<SessionNode> nodes) |
void |
setSessionConfirmStatusService(NodeConfirmStatusService<SessionNode> sessionConfirmStatusService)
Setter method for property sessionConfirmStatusService.
|
void |
setSessionRepositoryService(RepositoryService<String,RenewDecorate<SessionNode>> sessionRepositoryService)
Setter method for property sessionRepositoryService.
|
void |
setSessionVersionRepositoryService(VersionRepositoryService<String> sessionVersionRepositoryService)
Setter method for property sessionVersionRepositoryService.
|
void |
setTaskListenerManager(TaskListenerManager taskListenerManager)
Setter method for property taskListenerManager.
|
void |
updateOtherDataCenterNodes(DataCenterNodes 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<SessionNode>public NodeChangeResult setNodes(List<SessionNode> nodes)
setNodes 在接口中 StoreService<SessionNode>public NodeChangeResult addNode(SessionNode sessionNode)
StoreServiceaddNode 在接口中 StoreService<SessionNode>public boolean removeNode(String ipAddress)
StoreServiceremoveNode 在接口中 StoreService<SessionNode>public void removeNodes(Collection<SessionNode> nodes)
StoreServiceremoveNodes 在接口中 StoreService<SessionNode>public void reNew(SessionNode sessionNode, int duration)
StoreServicereNew 在接口中 StoreService<SessionNode>public Collection<SessionNode> getExpired()
StoreServicegetExpired 在接口中 StoreService<SessionNode>public Map<String,SessionNode> getNodes()
StoreServicegetNodes 在接口中 StoreService<SessionNode>public void pushNodeListChange()
StoreServicepushNodeListChange 在接口中 StoreService<SessionNode>public void confirmNodeStatus(String ipAddress, String confirmNodeIp)
StoreServiceconfirmNodeStatus 在接口中 StoreService<SessionNode>ipAddress - received Node ipAddressconfirmNodeIp - will be confirmed node ippublic NodeChangeResult getNodeChangeResult()
StoreServicegetNodeChangeResult 在接口中 StoreService<SessionNode>public void getOtherDataCenterNodeAndUpdate()
StoreServicepublic DataCenterNodes getDataCenterNodes()
StoreServicegetDataCenterNodes 在接口中 StoreService<SessionNode>public void updateOtherDataCenterNodes(DataCenterNodes dataCenterNodes)
StoreServiceupdateOtherDataCenterNodes 在接口中 StoreService<SessionNode>public void setTaskListenerManager(TaskListenerManager taskListenerManager)
taskListenerManager - value to be assigned to property taskListenerManagerpublic void setDataStoreService(StoreService dataStoreService)
dataStoreService - value to be assigned to property dataStoreServicepublic void setNodeConfig(NodeConfig nodeConfig)
nodeConfig - value to be assigned to property nodeConfigpublic void setSessionRepositoryService(RepositoryService<String,RenewDecorate<SessionNode>> sessionRepositoryService)
sessionRepositoryService - value to be assigned to property sessionRepositoryServicepublic void setSessionVersionRepositoryService(VersionRepositoryService<String> sessionVersionRepositoryService)
sessionVersionRepositoryService - value to be assigned to property sessionVersionRepositoryServicepublic NodeConfirmStatusService<SessionNode> getSessionConfirmStatusService()
public void setSessionConfirmStatusService(NodeConfirmStatusService<SessionNode> sessionConfirmStatusService)
sessionConfirmStatusService - value to be assigned to property sessionConfirmStatusServiceCopyright © 2019 The Ant Financial. All rights reserved.