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

接口 StoreService<T extends Node>

所有已知实现类:

DataStoreService, MetaStoreService, SessionStoreService

public interface StoreService<T extends Node>

interface for node store service

版本:

$Id: StoreService.java, v 0.1 2018-01-11 22:16 shangyu.wh Exp $

作者:

shangyu.wh

方法概要

限定符和类型	方法和说明
NodeChangeResult	addNode(T node) 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<T>	getExpired() get expired node list
NodeChangeResult	getNodeChangeResult() get node info request
Map<String,T>	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<T> nodes) remove current dataCenter dataNodes
void	reNew(T node, int duration) heartbeat update node expired time
NodeChangeResult	setNodes(List<T> nodes)
void	updateOtherDataCenterNodes(DataCenterNodes<T> dataCenterNodes) get other meta server node change update version and node info,and push current dataCenter node change info

方法详细资料

getNodeType

Node.NodeType getNodeType()

get node type

返回:

setNodes

NodeChangeResult setNodes(List<T> nodes)

addNode

NodeChangeResult addNode(T node)

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

参数:

node -

返回:

confirmNodeStatus

void confirmNodeStatus(String ipAddress,
                       String confirmNodeIp)

node change info push must be confirm received,

参数:

ipAddress - received Node ipAddress

confirmNodeIp - will be confirmed node ip

removeNode

boolean removeNode(String ipAddress)

remove current dataCenter dataNode by ipAddress

参数:

ipAddress -

返回:

removeNodes

void removeNodes(Collection<T> nodes)

remove current dataCenter dataNodes

参数:

nodes -

reNew

void reNew(T node,
           int duration)

heartbeat update node expired time

参数:

node -

getExpired

Collection<T> getExpired()

get expired node list

返回:

getNodes

Map<String,T> getNodes()

get all Nodes from all dataCenter

返回:

getNodeChangeResult

NodeChangeResult getNodeChangeResult()

get node info request

返回:

getOtherDataCenterNodeAndUpdate

void getOtherDataCenterNodeAndUpdate()

schedule check other dataCenter node change and update

updateOtherDataCenterNodes

void updateOtherDataCenterNodes(DataCenterNodes<T> dataCenterNodes)

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

参数:

dataCenterNodes -

getDataCenterNodes

DataCenterNodes getDataCenterNodes()

get DataCenter Nodes list contains version

返回:

pushNodeListChange

void pushNodeListChange()

push node change result