com.alipay.sofa.registry.server.meta.store

类 DataStoreService

java.lang.Object

com.alipay.sofa.registry.server.meta.store.DataStoreService

所有已实现的接口:

StoreService<DataNode>

public class DataStoreService
extends Object
implements StoreService<DataNode>

版本:

$Id: DataStoreService.java, v 0.1 2018-01-23 11:42 shangyu.wh Exp $

作者:

shangyu.wh

构造器概要

构造器

构造器和说明
DataStoreService()

方法概要

限定符和类型	方法和说明
NodeChangeResult	addNode(DataNode dataNode) 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<DataNode>	getExpired() only get local datacenter's dataNode, don't care other datacenter's dataNodes
NodeChangeResult	getNodeChangeResult() get node info request
Map<String,DataNode>	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<DataNode> nodes) remove current dataCenter dataNodes
void	reNew(DataNode dataNode, int duration) heartbeat update node expired time
void	setDataConfirmStatusService(NodeConfirmStatusService<DataNode> dataConfirmStatusService) Setter method for property dataConfirmStatusService.
void	setDataRepositoryService(RepositoryService<String,RenewDecorate<DataNode>> dataRepositoryService) Setter method for property dataRepositoryService.
void	setNodeConfig(NodeConfig nodeConfig) Setter method for property nodeConfig.
NodeChangeResult	setNodes(List<DataNode> nodes)
void	setTaskListenerManager(TaskListenerManager taskListenerManager) Setter method for property taskListenerManager.
void	updateOtherDataCenterNodes(DataCenterNodes<DataNode> dataCenterNodes) get other meta server node change update version and node info,and push current dataCenter node change info

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

DataStoreService

public DataStoreService()

方法详细资料

getNodeType

public Node.NodeType getNodeType()

从接口复制的说明: StoreService

get node type

指定者:

getNodeType 在接口中 StoreService<DataNode>

返回:

setNodes

public NodeChangeResult setNodes(List<DataNode> nodes)

指定者:

setNodes 在接口中 StoreService<DataNode>

addNode

public NodeChangeResult addNode(DataNode dataNode)

从接口复制的说明: StoreService

add new node,when renew request not found node will be add again

指定者:

addNode 在接口中 StoreService<DataNode>

返回:

removeNode

public boolean removeNode(String ipAddress)

从接口复制的说明: StoreService

remove current dataCenter dataNode by ipAddress

指定者:

removeNode 在接口中 StoreService<DataNode>

返回:

removeNodes

public void removeNodes(Collection<DataNode> nodes)

从接口复制的说明: StoreService

remove current dataCenter dataNodes

指定者:

removeNodes 在接口中 StoreService<DataNode>

reNew

public void reNew(DataNode dataNode,
                  int duration)

从接口复制的说明: StoreService

heartbeat update node expired time

指定者:

reNew 在接口中 StoreService<DataNode>

getExpired

public Collection<DataNode> getExpired()

only get local datacenter's dataNode, don't care other datacenter's dataNodes

指定者:

getExpired 在接口中 StoreService<DataNode>

返回:

getNodes

public Map<String,DataNode> getNodes()

从接口复制的说明: StoreService

get all Nodes from all dataCenter

指定者:

getNodes 在接口中 StoreService<DataNode>

返回:

getNodeChangeResult

public NodeChangeResult getNodeChangeResult()

从接口复制的说明: StoreService

get node info request

指定者:

getNodeChangeResult 在接口中 StoreService<DataNode>

返回:

pushNodeListChange

public void pushNodeListChange()

从接口复制的说明: StoreService

push node change result

指定者:

pushNodeListChange 在接口中 StoreService<DataNode>

confirmNodeStatus

public void confirmNodeStatus(String ipAddress,
                              String confirmNodeIp)

从接口复制的说明: StoreService

node change info push must be confirm received,

指定者:

confirmNodeStatus 在接口中 StoreService<DataNode>

参数:

ipAddress - received Node ipAddress

confirmNodeIp - will be confirmed node ip

getOtherDataCenterNodeAndUpdate

public void getOtherDataCenterNodeAndUpdate()

从接口复制的说明: StoreService

schedule check other dataCenter node change and update

指定者:

getOtherDataCenterNodeAndUpdate 在接口中 StoreService<DataNode>

updateOtherDataCenterNodes

public void updateOtherDataCenterNodes(DataCenterNodes<DataNode> dataCenterNodes)

从接口复制的说明: StoreService

get other meta server node change update version and node info,and push current dataCenter node change info

指定者:

updateOtherDataCenterNodes 在接口中 StoreService<DataNode>

getDataCenterNodes

public DataCenterNodes getDataCenterNodes()

从接口复制的说明: StoreService

get DataCenter Nodes list contains version

指定者:

getDataCenterNodes 在接口中 StoreService<DataNode>

返回:

setNodeConfig

public void setNodeConfig(NodeConfig nodeConfig)

Setter method for property nodeConfig.

参数:

nodeConfig - value to be assigned to property nodeConfig

setTaskListenerManager

public void setTaskListenerManager(TaskListenerManager taskListenerManager)

Setter method for property taskListenerManager.

参数:

taskListenerManager - value to be assigned to property taskListenerManager

setDataRepositoryService

public void setDataRepositoryService(RepositoryService<String,RenewDecorate<DataNode>> dataRepositoryService)

Setter method for property dataRepositoryService.

参数:

dataRepositoryService - value to be assigned to property dataRepositoryService

setDataConfirmStatusService

public void setDataConfirmStatusService(NodeConfirmStatusService<DataNode> dataConfirmStatusService)

Setter method for property dataConfirmStatusService.

参数:

dataConfirmStatusService - value to be assigned to property dataConfirmStatusService