public final class SlotTableCacheImpl extends Object implements SlotTableCache
| 构造器和说明 |
|---|
SlotTableCacheImpl() |
| 限定符和类型 | 方法和说明 |
|---|---|
protected void |
checkForSlotTable(String dataCenter,
long curEpoch,
SlotTable updating) |
long |
getEpoch(String dataCenter)
Gets get epoch.
|
String |
getLeader(String dataCenter,
int slotId)
Gets get leader.
|
SlotTable |
getLocalSlotTable()
Gets get current slot table.
|
Map<String,Long> |
getRemoteSlotTableEpoch() |
Slot |
getSlot(String dataCenter,
int slotId)
Gets get slot.
|
Slot |
getSlot(String dataCenter,
String dataInfoId)
Gets get slot.
|
SlotTable |
getSlotTable(String dataCenter) |
void |
init() |
protected SlotTableCacheImpl |
setRecorders(List<SlotTableRecorder> recorders) |
SlotTableCacheImpl |
setSessionServerConfig(SessionServerConfig sessionServerConfig)
Setter method for property sessionServerConfig.
|
int |
slotOf(String dataInfoId)
Slot of int.
|
boolean |
updateLocalSlotTable(SlotTable slotTable)
Update slot table boolean.
|
boolean |
updateRemoteSlotTable(Map<String,RemoteSlotTableStatus> remoteSlotTableStatus) |
@PostConstruct public void init()
public int slotOf(String dataInfoId)
SlotTableCacheslotOf 在接口中 SlotTableCachedataInfoId - the data info idpublic Slot getSlot(String dataCenter, String dataInfoId)
SlotTableCachegetSlot 在接口中 SlotTableCachedataCenter - dataCenterdataInfoId - the data info idpublic Slot getSlot(String dataCenter, int slotId)
SlotTableCachegetSlot 在接口中 SlotTableCachedataCenter - dataCenterslotId - the slot idpublic String getLeader(String dataCenter, int slotId)
SlotTableCachegetLeader 在接口中 SlotTableCachedataCenter - dataCenterslotId - the slot idpublic long getEpoch(String dataCenter)
SlotTableCachegetEpoch 在接口中 SlotTableCachedataCenter - dataCenterpublic boolean updateLocalSlotTable(SlotTable slotTable)
SlotTableCacheupdateLocalSlotTable 在接口中 SlotTableCacheslotTable - the slot tablepublic boolean updateRemoteSlotTable(Map<String,RemoteSlotTableStatus> remoteSlotTableStatus)
updateRemoteSlotTable 在接口中 SlotTableCacheprotected void checkForSlotTable(String dataCenter, long curEpoch, SlotTable updating)
public SlotTable getLocalSlotTable()
SlotTableCachegetLocalSlotTable 在接口中 SlotTableCachepublic Map<String,Long> getRemoteSlotTableEpoch()
getRemoteSlotTableEpoch 在接口中 SlotTableCachepublic SlotTable getSlotTable(String dataCenter)
getSlotTable 在接口中 SlotTableCacheprotected SlotTableCacheImpl setRecorders(List<SlotTableRecorder> recorders)
public SlotTableCacheImpl setSessionServerConfig(SessionServerConfig sessionServerConfig)
sessionServerConfig - value to be assigned to property sessionServerConfigCopyright © 2023 The Ant Financial. All rights reserved.