com.alipay.sofa.registry.server.session.node

类 AbstractNodeManager<T extends Node>

java.lang.Object

com.alipay.sofa.registry.server.session.node.AbstractNodeManager<T>

所有已实现的接口:

NodeManager<T>

直接已知子类:

DataNodeManager, MetaNodeManager, SessionNodeManager

public abstract class AbstractNodeManager<T extends Node>
extends Object
implements NodeManager<T>

版本:

$Id: AbstractNodeManager.java, v 0.1 2018-03-05 10:44 shangyu.wh Exp $

作者:

shangyu.wh

字段概要

字段

限定符和类型	字段和说明
protected NodeExchanger	metaNodeExchanger
protected Map<String,Map<String,T>>	nodes
protected RaftClientManager	raftClientManager
protected Lock	read
protected ReentrantReadWriteLock	readWriteLock
protected SessionServerConfig	sessionServerConfig
protected Lock	write

构造器概要

构造器

构造器和说明
AbstractNodeManager()

方法概要

限定符和类型	方法和说明
boolean	checkAndUpdateListVersions(String dataCenterId, Long version)
NodeChangeResult	getAllDataCenterNodes()
Collection<T>	getDataCenterNodes()
ConcurrentHashMap<String,Long>	getDataCenterNodesVersions() Getter method for property dataCenterNodesVersions.
Collection<String>	getDataCenters()
void	updateNodes(NodeChangeResult nodeChangeResult)

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

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

从接口继承的方法 com.alipay.sofa.registry.server.session.node.NodeManager

getNode, getNodeType, renewNode

字段详细资料

readWriteLock

protected final ReentrantReadWriteLock readWriteLock

read

protected final Lock read

write

protected final Lock write

nodes

protected Map<String,Map<String,T extends Node>> nodes

sessionServerConfig

@Autowired
protected SessionServerConfig sessionServerConfig

metaNodeExchanger

@Autowired
protected NodeExchanger metaNodeExchanger

raftClientManager

@Autowired
protected RaftClientManager raftClientManager

构造器详细资料

AbstractNodeManager

public AbstractNodeManager()

方法详细资料

getDataCenterNodes

public Collection<T> getDataCenterNodes()

指定者:

getDataCenterNodes 在接口中 NodeManager<T extends Node>

getDataCenters

public Collection<String> getDataCenters()

指定者:

getDataCenters 在接口中 NodeManager<T extends Node>

updateNodes

public void updateNodes(NodeChangeResult nodeChangeResult)

指定者:

updateNodes 在接口中 NodeManager<T extends Node>

checkAndUpdateListVersions

public boolean checkAndUpdateListVersions(String dataCenterId,
                                          Long version)

getAllDataCenterNodes

public NodeChangeResult getAllDataCenterNodes()

指定者:

getAllDataCenterNodes 在接口中 NodeManager<T extends Node>

getDataCenterNodesVersions

public ConcurrentHashMap<String,Long> getDataCenterNodesVersions()

Getter method for property dataCenterNodesVersions.

指定者:

getDataCenterNodesVersions 在接口中 NodeManager<T extends Node>

返回:

property value of dataCenterNodesVersions