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

接口 DataManager<DATA,ID,DATAINFOID>

所有已知子接口:

DataStore, Interests, Watchers

所有已知实现类:

AbstractDataManager, SessionDataStore, SessionInterests, SessionWatchers

public interface DataManager<DATA,ID,DATAINFOID>

Session Data store manager,according base data function

Session Data struct

- DataInfo ID | - Publisher List | - Subscriber List

版本:

$Id: DataManager.java, v 0.1 2017-11-30 17:57 shangyu.wh Exp $

作者:

shangyu.wh

方法概要

限定符和类型	方法和说明
boolean	add(DATA data) new publisher and subscriber data add
Tuple<Long,Long>	count() dataInfoId.size and data.size
Map<ID,DATA>	deleteByConnectId(ConnectId connectId) remove data by client node connectId
Map<ConnectId,Map<ID,DATA>>	deleteByConnectIds(Set<ConnectId> connectIds) remove data by client node connectIds
DATA	deleteById(ID registerId, DATAINFOID dataInfoId) remove single data by register id
void	forEach(java.util.function.BiConsumer<DATAINFOID,Map<ID,DATA>> consumer)
Set<ConnectId>	getConnectIds()
Collection<DATAINFOID>	getDataInfoIds()
List<DATA>	getDataList()
Map<DATAINFOID,Map<ID,DATA>>	getDatas()
Collection<DATA>	getDatas(DATAINFOID dataInfoId)
Map<ID,DATA>	queryByConnectId(ConnectId connectId) query data by client node connectId
Map<ConnectId,Map<ID,DATA>>	queryByConnectIds(Set<ConnectId> connectIds) query data by client node connectId
DATA	queryById(ID registerId, DATAINFOID dataInfoId)

方法详细资料

add

boolean add(DATA data)

new publisher and subscriber data add

参数:

data - data

返回:

boolean

queryByConnectId

Map<ID,DATA> queryByConnectId(ConnectId connectId)

query data by client node connectId

参数:

connectId - connectId

返回:

Map

queryByConnectIds

Map<ConnectId,Map<ID,DATA>> queryByConnectIds(Set<ConnectId> connectIds)

query data by client node connectId

参数:

connectIds - connectIds

返回:

Map

deleteByConnectId

Map<ID,DATA> deleteByConnectId(ConnectId connectId)

remove data by client node connectId

参数:

connectId - connectId

返回:

Map

deleteByConnectIds

Map<ConnectId,Map<ID,DATA>> deleteByConnectIds(Set<ConnectId> connectIds)

remove data by client node connectIds

参数:

connectIds - connectIds

返回:

Map

queryById

DATA queryById(ID registerId,
               DATAINFOID dataInfoId)

deleteById

DATA deleteById(ID registerId,
                DATAINFOID dataInfoId)

remove single data by register id

参数:

registerId - registerId

dataInfoId - dataInfoId

返回:

Data

count

Tuple<Long,Long> count()

dataInfoId.size and data.size

返回:

Tuple

getConnectIds

Set<ConnectId> getConnectIds()

getDatas

Collection<DATA> getDatas(DATAINFOID dataInfoId)

getDataList

List<DATA> getDataList()

getDatas

Map<DATAINFOID,Map<ID,DATA>> getDatas()

getDataInfoIds

Collection<DATAINFOID> getDataInfoIds()

forEach

void forEach(java.util.function.BiConsumer<DATAINFOID,Map<ID,DATA>> consumer)