Modifier and Type | Method and Description |
---|---|
IReplicationGroupBacklog |
ReplicationNode.getGroupBacklogByRequestContext(Object requestContext) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractSingleFileGroupBacklog<T extends IReplicationOrderedPacket,CType extends AbstractSingleFileConfirmationHolder>
A base class for
IReplicationGroupBacklog that contains a single IRedoLogFile and
treat the order of packets in that file for the global order of the backlog |
Modifier and Type | Method and Description |
---|---|
IReplicationOrderedPacket |
DefaultPacketFilteredHandler.packetFiltered(IReplicationOrderedPacket beforeFilter,
IReplicationOrderedPacket afterFilter,
IReplicationGroupBacklog groupBacklog,
String targetMemberName) |
IMarker |
SingleFileBacklogGroupMarker.SingleFileBacklogGroupMarkerWireForm.toFinalizedForm(IReplicationGroupBacklog backlog) |
IMarker |
SingleFileBacklogMarker.SingleFileBacklogMarkerWireForm.toFinalizedForm(IReplicationGroupBacklog backlog) |
Modifier and Type | Interface and Description |
---|---|
interface |
IReplicationAsyncGroupBacklog |
Modifier and Type | Class and Description |
---|---|
class |
AbstractGlobalOrderGroupBacklog |
class |
GlobalOrderAsyncGroupBacklog |
class |
GlobalOrderReliableAsyncGroupBacklog |
class |
GlobalOrderSyncGroupBacklog |
Modifier and Type | Method and Description |
---|---|
IReplicationOrderedPacket |
IPacketFilteredHandler.packetFiltered(IReplicationOrderedPacket beforeFilter,
IReplicationOrderedPacket afterFilter,
IReplicationGroupBacklog groupBacklog,
String targetMemberName) |
IReplicationOrderedPacket |
GlobalOrderReliableAsyncGroupBacklog.packetFiltered(IReplicationOrderedPacket beforeFilter,
IReplicationOrderedPacket afterFilter,
IReplicationGroupBacklog groupBacklog,
String targetMemberName) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractMultiBucketSingleFileGroupBacklog |
class |
MultiBucketSingleFileReliableAsyncGroupBacklog |
class |
MultiBucketSingleFileSyncGroupBacklog |
Modifier and Type | Method and Description |
---|---|
IReplicationOrderedPacket |
MultiBucketSingleFileReliableAsyncGroupBacklog.packetFiltered(IReplicationOrderedPacket beforeFilter,
IReplicationOrderedPacket afterFilter,
IReplicationGroupBacklog groupBacklog,
String targetMemberName) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractMultiSourceSingleFileGroupBacklog |
class |
MultiSourceSingleFileAsyncGroupBacklog |
class |
MultiSourceSingleFileReliableAsyncGroupBacklog |
Modifier and Type | Method and Description |
---|---|
IReplicationOrderedPacket |
MultiSourceSingleFileReliableAsyncGroupBacklog.packetFiltered(IReplicationOrderedPacket beforeFilter,
IReplicationOrderedPacket afterFilter,
IReplicationGroupBacklog groupBacklog,
String targetMemberName) |
Modifier and Type | Interface and Description |
---|---|
interface |
IReplicationReliableAsyncGroupBacklog |
Modifier and Type | Interface and Description |
---|---|
interface |
IReplicationSyncGroupBacklog |
Modifier and Type | Method and Description |
---|---|
IMarker |
IMarkerWireForm.toFinalizedForm(IReplicationGroupBacklog backlog) |
Modifier and Type | Method and Description |
---|---|
IReplicationGroupBacklog |
DirectPersistencySyncHandler.getBackLog() |
IReplicationGroupBacklog |
IDirectPersistencySyncHandler.getBackLog() |
Modifier and Type | Method and Description |
---|---|
void |
DirectPersistencySyncHandler.setBackLog(IReplicationGroupBacklog backlog) |
void |
IDirectPersistencySyncHandler.setBackLog(IReplicationGroupBacklog backlog) |
Modifier and Type | Method and Description |
---|---|
IReplicationGroupBacklog |
AbstractReplicationSourceChannel.getGroupBacklog() |
IReplicationGroupBacklog |
IReplicationSourceGroup.getGroupBacklog() |
IReplicationGroupBacklog |
AbstractReplicationSourceGroup.getGroupBacklog() |
Modifier and Type | Method and Description |
---|---|
static <T extends IReplicationOrderedPacket> |
ReplicationChannelDataFilterHelper.filterPacket(IReplicationChannelDataFilter filter,
PlatformLogicalVersion targetMemberVersion,
T packet,
IReplicationPacketDataProducer dataProducer,
IReplicationGroupBacklog groupBacklog,
T previousDiscardedPacket,
org.slf4j.Logger logger,
String targetMemberName) |
protected static <T extends IReplicationOrderedPacket> |
ReplicationChannelDataFilterHelper.filterSingleEntryDataPacket(IReplicationChannelDataFilter filter,
PlatformLogicalVersion targetMemberVersion,
T packet,
IReplicationPacketDataProducer dataProducer,
IReplicationGroupBacklog groupBacklog,
T previousDiscardedPacket,
org.slf4j.Logger logger,
String targetMemberName) |
Constructor and Description |
---|
SyncReplicationSourceChannel(DynamicSourceGroupConfigHolder groupConfig,
String groupName,
String memberName,
IReplicationRouter replicationRouter,
IReplicationMonitoredConnection connection,
IReplicationGroupBacklog groupBacklog,
IReplicationOutFilter outFilter,
IReplicationThrottleController throttleController,
IAsyncHandlerProvider asyncHandlerProvider,
int asyncStateBatchSize,
long idleDelayMilis,
IReplicationChannelDataFilter dataFilter,
IReplicationSourceGroupStateListener stateListener,
IReplicationGroupHistory groupHistory,
ReplicationStatistics.ReplicationMode channelType,
Object customBacklogMetadata) |
Modifier and Type | Method and Description |
---|---|
IReplicationGroupBacklog |
ReplicationNodeReplicaHandler.getGroupBacklogByRequestContext(Object requestContext) |
Copyright © GigaSpaces.