com.alipay.sofa.registry.server.session.store

接口 Interests

所有超级接口:

DataManager<Subscriber,String,String>

所有已知实现类:

SessionInterests

public interface Interests
extends DataManager<Subscriber,String,String>

版本:

$Id: SessionInterests.java, v 0.1 2017-11-30 15:53 shangyu.wh Exp $

作者:

shangyu.wh

嵌套类概要

嵌套类

限定符和类型	接口和说明
static class	Interests.InterestVersionCheck

方法概要

限定符和类型	方法和说明
Interests.InterestVersionCheck	checkInterestVersion(String dataCenter, String datumDataInfoId, long version) check subscribers interest dataInfoId version,very dataCenter dataInfoId version different if return false else check return bigger version
Map<String,List<String>>	filterIPs(String group, int limit)
Collection<Subscriber>	getInterests(String datumDataInfoId)
SessionRegistry.SelectSubscriber	selectSubscribers(Set<String> dataCenters)

从接口继承的方法 com.alipay.sofa.registry.server.session.store.DataManager

add, count, deleteByConnectId, deleteByConnectIds, deleteById, forEach, getConnectIds, getDataInfoIds, getDataList, getDatas, getDatas, queryByConnectId, queryByConnectIds, queryById

方法详细资料

checkInterestVersion

Interests.InterestVersionCheck checkInterestVersion(String dataCenter,
                                                    String datumDataInfoId,
                                                    long version)

check subscribers interest dataInfoId version,very dataCenter dataInfoId version different if return false else check return bigger version

参数:

dataCenter - dataCenter

datumDataInfoId - datumDataInfoId

version - version

返回:

InterestVersionCheck

getInterests

Collection<Subscriber> getInterests(String datumDataInfoId)

selectSubscribers

SessionRegistry.SelectSubscriber selectSubscribers(Set<String> dataCenters)

filterIPs

Map<String,List<String>> filterIPs(String group,
                                   int limit)