Modifier and Type | Class and Description |
---|---|
class |
DataTypeAddIndexPacketData |
class |
DataTypeIntroducePacketData |
Modifier and Type | Class and Description |
---|---|
class |
SynchronizingData<T extends IReplicationPacketData<?>> |
Modifier and Type | Method and Description |
---|---|
IReplicationPacketData<?> |
GlobalOrderDiscardedReplicationPacket.getData() |
IReplicationPacketData<?> |
GlobalOrderReliableAsyncKeptDiscardedOrderedPacket.getData() |
IReplicationPacketData |
GlobalOrderOperationPacket.getData() |
IReplicationPacketData |
GlobalOrderDeletedBacklogPacket.getData() |
Modifier and Type | Method and Description |
---|---|
IReplicationOrderedPacket |
GlobalOrderDiscardedReplicationPacket.cloneWithNewData(IReplicationPacketData<?> newData) |
IReplicationOrderedPacket |
GlobalOrderReliableAsyncKeptDiscardedOrderedPacket.cloneWithNewData(IReplicationPacketData<?> newData) |
IReplicationOrderedPacket |
GlobalOrderOperationPacket.cloneWithNewData(IReplicationPacketData<?> newData) |
IReplicationOrderedPacket |
GlobalOrderDeletedBacklogPacket.cloneWithNewData(IReplicationPacketData<?> newData) |
Constructor and Description |
---|
GlobalOrderOperationPacket(long key,
IReplicationPacketData data) |
Modifier and Type | Method and Description |
---|---|
IReplicationPacketData<?> |
MultiBucketSingleFileReliableAsyncKeptDiscardedPacket.getData() |
IReplicationPacketData<?> |
SingleBucketOrderedPacket.getData() |
IReplicationPacketData<?> |
MultipleBucketOrderedPacket.getData() |
IReplicationPacketData<?> |
DeletedMultiBucketOrderedPacket.getData() |
IReplicationPacketData<?> |
DiscardedMultiBucketOrderedPacket.getData() |
IReplicationPacketData<?> |
DiscardedSingleBucketOrderedPacket.getData() |
Constructor and Description |
---|
MultipleBucketOrderedPacket(long globalKey,
ShortObjectMap<BucketKey> bucketsKeys,
IReplicationPacketData<?> data) |
SingleBucketOrderedPacket(long globalKey,
long bucketKey,
short bucketIndex,
IReplicationPacketData<?> data) |
Modifier and Type | Method and Description |
---|---|
void |
IReplicationInFilterCallback.invokeInFilter(IReplicationInContext context,
IReplicationPacketData<?> data)
Callback method for the data consumer to invoke input filters before executing the packet
|
Modifier and Type | Method and Description |
---|---|
ReplicationChannelEntryDataFilterResult |
NotificationReplicationChannelDataFilter.filterBeforeReplicatingEntryData(IReplicationPacketEntryData packetEntryData,
PlatformLogicalVersion targetLogicalVersion,
IReplicationPacketEntryDataContentExtractor contentExtractor,
Logger contextLogger,
IReplicationPacketData<?> data) |
Modifier and Type | Method and Description |
---|---|
IReplicationPacketData<?> |
IReplicationOrderedPacket.getData() |
Modifier and Type | Method and Description |
---|---|
IReplicationOrderedPacket |
IReplicationOrderedPacket.cloneWithNewData(IReplicationPacketData<?> newData)
Clones the packet replacing its data with the new data
|
Modifier and Type | Interface and Description |
---|---|
interface |
IReplicationPacketDataBatchConsumer<T extends IReplicationPacketData<?>> |
interface |
IReplicationPacketDataConsumer<T extends IReplicationPacketData<?>>
Consumes
IReplicationPacketData and delegate it to the corresponding replication in
handler. |
interface |
IReplicationPacketDataProducer<T extends IReplicationPacketData<?>>
Convert logical operation to a representing
IReplicationPacketData |
Modifier and Type | Interface and Description |
---|---|
interface |
IExecutableReplicationPacketData<T extends IReplicationPacketEntryData>
An extension of
IReplicationPacketData that can be self executed. |
Modifier and Type | Class and Description |
---|---|
class |
DiscardReplicationPacketData |
Modifier and Type | Method and Description |
---|---|
IReplicationPacketData<T> |
IReplicationPacketData.clone() |
IReplicationPacketData<?> |
IReplicationPacketDataConsumer.merge(IReplicationPacketData<?>[] allParticipantsData,
IReplicationParticipantsMetadata participantsMetadata)
Merges data of multiple participants operations to a single operation data which will
eventually be executed as one.
|
IReplicationPacketData<?> |
ReplicationPacketDataConsumer.merge(IReplicationPacketData<?>[] allParticipantsData,
IReplicationParticipantsMetadata participantsMetadata) |
Modifier and Type | Method and Description |
---|---|
IReplicationParticipantsMetadata |
IReplicationPacketDataConsumer.extractParticipantsMetadata(IReplicationPacketData<?> data)
Extracts participants meta data for the provided replication packet data
|
IReplicationParticipantsMetadata |
ReplicationPacketDataConsumer.extractParticipantsMetadata(IReplicationPacketData<?> data) |
IReplicationPacketData<?> |
IReplicationPacketDataConsumer.merge(IReplicationPacketData<?>[] allParticipantsData,
IReplicationParticipantsMetadata participantsMetadata)
Merges data of multiple participants operations to a single operation data which will
eventually be executed as one.
|
IReplicationPacketData<?> |
ReplicationPacketDataConsumer.merge(IReplicationPacketData<?>[] allParticipantsData,
IReplicationParticipantsMetadata participantsMetadata) |
Iterable<IReplicationFilterEntry> |
IReplicationPacketDataConsumer.toFilterEntries(IReplicationInContext context,
IReplicationPacketData<?> data)
Transform generated data to filter entry in order to be passed to a filter
|
Iterable<IReplicationFilterEntry> |
ReplicationPacketDataConsumer.toFilterEntries(IReplicationInContext context,
IReplicationPacketData<?> data) |
Modifier and Type | Method and Description |
---|---|
<T extends IReplicationPacketData<?>> |
AbstractSingleFileTargetProcessLog.getDataConsumer() |
<T extends IReplicationPacketData<?>> |
IReplicationTargetProcessLog.getDataConsumer() |
Modifier and Type | Method and Description |
---|---|
IReplicationPacketData<?>[] |
IReplicationParticipantsMediator.getAllParticipantsData(MultiSourceProcessLogPacket packet)
Gets all data for a multiple participants replication operation.
|
IReplicationPacketData<?>[] |
ReplicationParticipantsMediator.getAllParticipantsData(MultiSourceProcessLogPacket packet) |
IReplicationPacketData<?> |
MultiSourceProcessLogMultiParticipantPacket.getData() |
IReplicationPacketData<?> |
MultiSourceProcessLogPacket.getData() |
Modifier and Type | Method and Description |
---|---|
void |
MultiSourceProcessLogMultiParticipantPacket.setData(IReplicationPacketData<?> mergedData) |
void |
MultiSourceProcessLogPacket.setData(IReplicationPacketData<?> mergedData) |
Modifier and Type | Method and Description |
---|---|
ReplicationChannelEntryDataFilterResult |
ViewReplicationChannelDataFilter.filterBeforeReplicatingEntryData(IReplicationPacketEntryData entryData,
PlatformLogicalVersion targetLogicalVersion,
IReplicationPacketEntryDataContentExtractor contentExtractor,
Logger contextLogger,
IReplicationPacketData data) |
Copyright © GigaSpaces.