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

类 DataNodeServiceImpl

java.lang.Object

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

所有已实现的接口:

DataNodeService

public class DataNodeServiceImpl
extends Object
implements DataNodeService

版本:

$Id: DataNode.java, v 0.1 2017-12-01 11:30 shangyu.wh Exp $

作者:

shangyu.wh

构造器概要

构造器

构造器和说明
DataNodeServiceImpl()

方法概要

限定符和类型	方法和说明
void	clientOff(List<String> connectIds) session server support api to stop some client node,all register data on data server will be removed data on session server will be remove too
Datum	fetchDataCenter(String dataInfoId, String dataCenterId) fetch one dataCenter publisher data from data server
Map<String,Map<String,Long>>	fetchDataVersion(URL dataNodeUrl, Collection<String> dataInfoIdList) Get some dataInfoId version from one data server
Map<String,Datum>	fetchGlobal(String dataInfoId) fetch all dataCenter datum
Map<String,Datum>	getDatumMap(String dataInfoId, String dataCenterId) fetch datum by specify dataCenter and dataInfoId
void	register(Publisher publisher) new publisher data transform to data server
void	registerSessionProcessId(SessionServerRegisterRequest sessionServerRegisterRequest, URL dataUrl) register session process id when connect to data node process id see SessionProcessIdGenerator
void	unregister(Publisher publisher) remove publisher data from data server

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

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

构造器详细资料

DataNodeServiceImpl

public DataNodeServiceImpl()

方法详细资料

register

public void register(Publisher publisher)

从接口复制的说明: DataNodeService

new publisher data transform to data server

指定者:

register 在接口中 DataNodeService

unregister

public void unregister(Publisher publisher)

从接口复制的说明: DataNodeService

remove publisher data from data server

指定者:

unregister 在接口中 DataNodeService

clientOff

public void clientOff(List<String> connectIds)

从接口复制的说明: DataNodeService

session server support api to stop some client node,all register data on data server will be removed data on session server will be remove too

指定者:

clientOff 在接口中 DataNodeService

registerSessionProcessId

public void registerSessionProcessId(SessionServerRegisterRequest sessionServerRegisterRequest,
                                     URL dataUrl)

从接口复制的说明: DataNodeService

register session process id when connect to data node process id see SessionProcessIdGenerator

指定者:

registerSessionProcessId 在接口中 DataNodeService

fetchDataVersion

public Map<String,Map<String,Long>> fetchDataVersion(URL dataNodeUrl,
                                                     Collection<String> dataInfoIdList)

从接口复制的说明: DataNodeService

Get some dataInfoId version from one data server

指定者:

fetchDataVersion 在接口中 DataNodeService

返回:

fetchDataCenter

public Datum fetchDataCenter(String dataInfoId,
                             String dataCenterId)

从接口复制的说明: DataNodeService

fetch one dataCenter publisher data from data server

指定者:

fetchDataCenter 在接口中 DataNodeService

返回:

fetchGlobal

public Map<String,Datum> fetchGlobal(String dataInfoId)

从接口复制的说明: DataNodeService

fetch all dataCenter datum

指定者:

fetchGlobal 在接口中 DataNodeService

返回:

getDatumMap

public Map<String,Datum> getDatumMap(String dataInfoId,
                                     String dataCenterId)

从接口复制的说明: DataNodeService

fetch datum by specify dataCenter and dataInfoId

指定者:

getDatumMap 在接口中 DataNodeService

返回: