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(ClientOffPublishers clientOffPublishers) 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
MultiSubDatum	fetch(String dataInfoId, Set<String> dataCenters) fetch one dataCenter publisher data from data server
void	fetchDataVersion(String dataCenter, int slotId, Map<String,DatumVersion> interests, ExchangeCallback<Map<String,DatumVersion>> callback)
void	init()
void	register(Publisher publisher) new publisher data transform to data server
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()

方法详细资料

init

@PostConstruct
public void init()

register

public void register(Publisher publisher)

从接口复制的说明: DataNodeService

new publisher data transform to data server

指定者:

register 在接口中 DataNodeService

参数:

publisher - publisher

unregister

public void unregister(Publisher publisher)

从接口复制的说明: DataNodeService

remove publisher data from data server

指定者:

unregister 在接口中 DataNodeService

参数:

publisher - publisher

clientOff

public void clientOff(ClientOffPublishers clientOffPublishers)

从接口复制的说明: 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

参数:

clientOffPublishers - clientOffPublishers

fetchDataVersion

public void fetchDataVersion(String dataCenter,
                             int slotId,
                             Map<String,DatumVersion> interests,
                             ExchangeCallback<Map<String,DatumVersion>> callback)

指定者:

fetchDataVersion 在接口中 DataNodeService

fetch

public MultiSubDatum fetch(String dataInfoId,
                           Set<String> dataCenters)

从接口复制的说明: DataNodeService

fetch one dataCenter publisher data from data server

指定者:

fetch 在接口中 DataNodeService

参数:

dataInfoId - dataInfoId

dataCenters - dataCenters

返回:

MultiSubDatum