Uses of Interface
com.gigaspaces.internal.cluster.node.impl.packets.data.IReplicationPacketData

Packages that use IReplicationPacketData

Package	Description
com.gigaspaces.internal.cluster.node.impl
com.gigaspaces.internal.cluster.node.impl.backlog
com.gigaspaces.internal.cluster.node.impl.backlog.globalorder
com.gigaspaces.internal.cluster.node.impl.backlog.multibucketsinglefile
com.gigaspaces.internal.cluster.node.impl.filters
com.gigaspaces.internal.cluster.node.impl.groups
com.gigaspaces.internal.cluster.node.impl.groups.reliableasync
com.gigaspaces.internal.cluster.node.impl.notification
com.gigaspaces.internal.cluster.node.impl.packets
com.gigaspaces.internal.cluster.node.impl.packets.data
com.gigaspaces.internal.cluster.node.impl.packets.data.operations
com.gigaspaces.internal.cluster.node.impl.processlog
com.gigaspaces.internal.cluster.node.impl.processlog.multisourcesinglefile
com.gigaspaces.internal.cluster.node.impl.view

Uses of IReplicationPacketData in com.gigaspaces.internal.cluster.node.impl

Classes in com.gigaspaces.internal.cluster.node.impl that implement IReplicationPacketData

Modifier and Type	Class and Description
class	DataTypeAddIndexPacketData
class	DataTypeDropPacketData
class	DataTypeIntroducePacketData

Uses of IReplicationPacketData in com.gigaspaces.internal.cluster.node.impl.backlog

Classes in com.gigaspaces.internal.cluster.node.impl.backlog with type parameters of type IReplicationPacketData

Modifier and Type	Class and Description
class	SynchronizingData<T extends IReplicationPacketData<?>>

Methods in com.gigaspaces.internal.cluster.node.impl.backlog with parameters of type IReplicationPacketData

Modifier and Type	Method and Description
int	BacklogWeightPolicy.calculateWeight(IReplicationPacketData<?> data)
int	AccumulatedBacklogWeightPolicy.calculateWeight(IReplicationPacketData<?> data)
int	FixedBacklogWeightPolicy.calculateWeight(IReplicationPacketData<?> data)
protected void	AbstractSingleFileGroupBacklog.ensureLimit(IReplicationPacketData<?> data)
protected void	AbstractSingleFileGroupBacklog.setPacketWeight(IReplicationPacketData<?> data)
protected boolean	AbstractSingleFileGroupBacklog.shouldInsertPacket(IReplicationPacketData<?> data)

Uses of IReplicationPacketData in com.gigaspaces.internal.cluster.node.impl.backlog.globalorder

Methods in com.gigaspaces.internal.cluster.node.impl.backlog.globalorder that return IReplicationPacketData

Modifier and Type	Method and Description
IReplicationPacketData<?>	GlobalOrderReliableAsyncKeptDiscardedOrderedPacket.getData()
IReplicationPacketData	GlobalOrderDeletedBacklogPacket.getData()
IReplicationPacketData	GlobalOrderOperationPacket.getData()
IReplicationPacketData<?>	GlobalOrderDiscardedReplicationPacket.getData()

Methods in com.gigaspaces.internal.cluster.node.impl.backlog.globalorder with parameters of type IReplicationPacketData

Modifier and Type	Method and Description
IReplicationOrderedPacket	GlobalOrderReliableAsyncKeptDiscardedOrderedPacket.cloneWithNewData(IReplicationPacketData<?> newData)
IReplicationOrderedPacket	GlobalOrderDeletedBacklogPacket.cloneWithNewData(IReplicationPacketData<?> newData)
IReplicationOrderedPacket	GlobalOrderOperationPacket.cloneWithNewData(IReplicationPacketData<?> newData)
IReplicationOrderedPacket	GlobalOrderDiscardedReplicationPacket.cloneWithNewData(IReplicationPacketData<?> newData)

Constructors in com.gigaspaces.internal.cluster.node.impl.backlog.globalorder with parameters of type IReplicationPacketData

Constructor and Description
GlobalOrderOperationPacket(long key, IReplicationPacketData data)

Uses of IReplicationPacketData in com.gigaspaces.internal.cluster.node.impl.backlog.multibucketsinglefile

Methods in com.gigaspaces.internal.cluster.node.impl.backlog.multibucketsinglefile that return IReplicationPacketData

Modifier and Type	Method and Description
IReplicationPacketData<?>	MultipleBucketOrderedPacket.getData()
IReplicationPacketData<?>	DiscardedSingleBucketOrderedPacket.getData()
IReplicationPacketData<?>	SingleBucketOrderedPacket.getData()
IReplicationPacketData<?>	MultiBucketSingleFileReliableAsyncKeptDiscardedPacket.getData()
IReplicationPacketData<?>	DeletedMultiBucketOrderedPacket.getData()
IReplicationPacketData<?>	DiscardedMultiBucketOrderedPacket.getData()

Methods in com.gigaspaces.internal.cluster.node.impl.backlog.multibucketsinglefile with parameters of type IReplicationPacketData

Modifier and Type	Method and Description
IMultiBucketSingleFileReplicationOrderedPacket	IMultiBucketSingleFileReplicationOrderedPacket.cloneWithNewData(IReplicationPacketData<?> newData)
MultipleBucketOrderedPacket	MultipleBucketOrderedPacket.cloneWithNewData(IReplicationPacketData<?> newData)
DiscardedSingleBucketOrderedPacket	DiscardedSingleBucketOrderedPacket.cloneWithNewData(IReplicationPacketData<?> newData)
SingleBucketOrderedPacket	SingleBucketOrderedPacket.cloneWithNewData(IReplicationPacketData<?> newData)
MultiBucketSingleFileReliableAsyncKeptDiscardedPacket	MultiBucketSingleFileReliableAsyncKeptDiscardedPacket.cloneWithNewData(IReplicationPacketData<?> newData)
IMultiBucketSingleFileReplicationOrderedPacket	DeletedMultiBucketOrderedPacket.cloneWithNewData(IReplicationPacketData<?> newData)
IMultiBucketSingleFileReplicationOrderedPacket	DiscardedMultiBucketOrderedPacket.cloneWithNewData(IReplicationPacketData<?> newData)

Constructors in com.gigaspaces.internal.cluster.node.impl.backlog.multibucketsinglefile with parameters of type IReplicationPacketData

Constructor and Description
MultipleBucketOrderedPacket(long globalKey, ShortObjectMap<BucketKey> bucketsKeys, IReplicationPacketData<?> data)
SingleBucketOrderedPacket(long globalKey, long bucketKey, short bucketIndex, IReplicationPacketData<?> data)

Uses of IReplicationPacketData in com.gigaspaces.internal.cluster.node.impl.filters

Methods in com.gigaspaces.internal.cluster.node.impl.filters with parameters of type IReplicationPacketData

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

Uses of IReplicationPacketData in com.gigaspaces.internal.cluster.node.impl.groups

Methods in com.gigaspaces.internal.cluster.node.impl.groups with parameters of type IReplicationPacketData

Modifier and Type	Method and Description
ReplicationChannelDataFilterResult	IReplicationChannelDataFilter.filterBeforeReplicatingData(IReplicationPacketData<?> data, PlatformLogicalVersion targetLogicalVersion, org.slf4j.Logger contextLogger) Specifies whether the given data should pass the filter as is, be converted or removed
ReplicationChannelDataFilterResult	GeneralReplicationChannelDataFilter.filterBeforeReplicatingData(IReplicationPacketData<?> data, PlatformLogicalVersion targetLogicalVersion, org.slf4j.Logger contextLogger)
ReplicationChannelEntryDataFilterResult	GeneralReplicationChannelDataFilter.filterBeforeReplicatingEntryData(IReplicationPacketEntryData entryData, PlatformLogicalVersion targetLogicalVersion, IReplicationPacketEntryDataContentExtractor contentExtractor, org.slf4j.Logger contextLogger, IReplicationPacketData data)
ReplicationChannelEntryDataFilterResult	ReliableAsyncKeeperLruCentralDataSourceReplicationChannelDataFilter.filterBeforeReplicatingEntryData(IReplicationPacketEntryData entryData, PlatformLogicalVersion targetLogicalVersion, IReplicationPacketEntryDataContentExtractor contentExtractor, org.slf4j.Logger contextLogger, IReplicationPacketData data)
ReplicationChannelEntryDataFilterResult	IReplicationChannelDataFilter.filterBeforeReplicatingEntryData(IReplicationPacketEntryData entryData, PlatformLogicalVersion targetLogicalVersion, IReplicationPacketEntryDataContentExtractor contentExtractor, org.slf4j.Logger contextLogger, IReplicationPacketData<?> data) Specifies whether the given entry data should pass the filter as is, be converted or removed
void	AbstractReplicationTargetChannel.invokeInFilter(IReplicationInContext context, IReplicationPacketData<?> data)

Uses of IReplicationPacketData in com.gigaspaces.internal.cluster.node.impl.groups.reliableasync

Methods in com.gigaspaces.internal.cluster.node.impl.groups.reliableasync with parameters of type IReplicationPacketData

Modifier and Type	Method and Description
ReplicationChannelDataFilterResult	ReliableAsyncChannelDataFilter.filterBeforeReplicatingData(IReplicationPacketData<?> data, PlatformLogicalVersion targetLogicalVersion, org.slf4j.Logger contextLogger)
ReplicationChannelDataFilterResult	GatewayChannelDataFilter.filterBeforeReplicatingData(IReplicationPacketData<?> data, PlatformLogicalVersion targetLogicalVersion, org.slf4j.Logger contextLogger)
ReplicationChannelEntryDataFilterResult	MirrorChannelDataFilter.filterBeforeReplicatingEntryData(IReplicationPacketEntryData entryData, PlatformLogicalVersion targetLogicalVersion, IReplicationPacketEntryDataContentExtractor contentExtractor, org.slf4j.Logger contextLogger, IReplicationPacketData data)
ReplicationChannelEntryDataFilterResult	GatewayChannelDataFilter.filterBeforeReplicatingEntryData(IReplicationPacketEntryData entryData, PlatformLogicalVersion targetLogicalVersion, IReplicationPacketEntryDataContentExtractor contentExtractor, org.slf4j.Logger contextLogger, IReplicationPacketData data)

Uses of IReplicationPacketData in com.gigaspaces.internal.cluster.node.impl.notification

Methods in com.gigaspaces.internal.cluster.node.impl.notification with parameters of type IReplicationPacketData

Modifier and Type	Method and Description
ReplicationChannelEntryDataFilterResult	NotificationReplicationChannelDataFilter.filterBeforeReplicatingEntryData(IReplicationPacketEntryData packetEntryData, PlatformLogicalVersion targetLogicalVersion, IReplicationPacketEntryDataContentExtractor contentExtractor, org.slf4j.Logger contextLogger, IReplicationPacketData<?> data)

Uses of IReplicationPacketData in com.gigaspaces.internal.cluster.node.impl.packets

Methods in com.gigaspaces.internal.cluster.node.impl.packets that return IReplicationPacketData

Modifier and Type	Method and Description
IReplicationPacketData<?>	IReplicationOrderedPacket.getData()

Methods in com.gigaspaces.internal.cluster.node.impl.packets with parameters of type IReplicationPacketData

Modifier and Type	Method and Description
IReplicationOrderedPacket	IReplicationOrderedPacket.cloneWithNewData(IReplicationPacketData<?> newData) Clones the packet replacing its data with the new data

Uses of IReplicationPacketData in com.gigaspaces.internal.cluster.node.impl.packets.data

Classes in com.gigaspaces.internal.cluster.node.impl.packets.data with type parameters of type IReplicationPacketData

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

Subinterfaces of IReplicationPacketData in com.gigaspaces.internal.cluster.node.impl.packets.data

Modifier and Type	Interface and Description
interface	IExecutableReplicationPacketData<T extends IReplicationPacketEntryData> An extension of IReplicationPacketData that can be self executed.

Classes in com.gigaspaces.internal.cluster.node.impl.packets.data that implement IReplicationPacketData

Modifier and Type	Class and Description
class	DiscardReplicationPacketData

Methods in com.gigaspaces.internal.cluster.node.impl.packets.data that return IReplicationPacketData

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)

Methods in com.gigaspaces.internal.cluster.node.impl.packets.data with parameters of type IReplicationPacketData

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)

Uses of IReplicationPacketData in com.gigaspaces.internal.cluster.node.impl.packets.data.operations

Classes in com.gigaspaces.internal.cluster.node.impl.packets.data.operations that implement IReplicationPacketData

Modifier and Type	Class and Description
class	AbstractPrepareDependentTransactionReplicationPacketData Base class for replication packets that depend on a previous TransactionPrepareReplicationPacketData occurring
class	AbstractReplicationPacketSingleEntryData A base class for IReplicationPacketData implementations that contains only one IReplicationPacketEntryData
class	AbstractTransactionReplicationPacketData Base class for transaction replication packet data
class	CancelLeaseFullReplicationPacketData
class	CancelLeaseReplicationPacketData
class	ChangeReplicationPacketData
class	EntryLeaseExpiredFullReplicationPacketData
class	EntryLeaseExpiredReplicationPacketData
class	EvictReplicationPacketData
class	ExtendEntryLeaseReplicationPacketData
class	ExtendNotifyTemplateLeaseReplicationPacketData
class	InsertNotifyTemplateReplicationPacketData
class	NotifyTemplateLeaseExpiredReplicationPacketData
class	PartialUpdateReplicationPacketData
class	RemoveByUIDReplicationPacketData
class	RemoveNotifyTemplateReplicationPacketData
class	RemoveReplicationPacketData
class	SingleReplicationPacketData
class	SingleUidReplicationPacketData
class	TransactionAbortReplicationPacketData Replication packet representing transaction abort
class	TransactionCommitReplicationPacketData Replication packet representing transaction commit
class	TransactionOnePhaseReplicationPacketData Replication packet representing a one phase commit transaction
class	TransactionPrepareReplicationPacketData Replication packet representing transaction prepare
class	TransactionReplicationPacketData Deprecated. since 9.0.0 - see TransactionOnePhaseReplicationPacketData
class	UpdateReplicationPacketData
class	WriteReplicationPacketData

Uses of IReplicationPacketData in com.gigaspaces.internal.cluster.node.impl.processlog

Methods in com.gigaspaces.internal.cluster.node.impl.processlog with type parameters of type IReplicationPacketData

Modifier and Type	Method and Description
<T extends IReplicationPacketData<?>> IReplicationPacketDataConsumer<T>	IReplicationTargetProcessLog.getDataConsumer()
<T extends IReplicationPacketData<?>> IReplicationPacketDataConsumer<T>	AbstractSingleFileTargetProcessLog.getDataConsumer()

Uses of IReplicationPacketData in com.gigaspaces.internal.cluster.node.impl.processlog.multisourcesinglefile

Methods in com.gigaspaces.internal.cluster.node.impl.processlog.multisourcesinglefile that return IReplicationPacketData

Modifier and Type	Method and Description
IReplicationPacketData<?>[]	ReplicationParticipantsMediator.getAllParticipantsData(MultiSourceProcessLogPacket packet)
IReplicationPacketData<?>[]	IReplicationParticipantsMediator.getAllParticipantsData(MultiSourceProcessLogPacket packet) Gets all data for a multiple participants replication operation.
IReplicationPacketData<?>	MultiSourceProcessLogPacket.getData()
IReplicationPacketData<?>	MultiSourceProcessLogMultiParticipantPacket.getData()

Methods in com.gigaspaces.internal.cluster.node.impl.processlog.multisourcesinglefile with parameters of type IReplicationPacketData

Modifier and Type	Method and Description
void	MultiSourceProcessLogPacket.setData(IReplicationPacketData<?> mergedData)
void	MultiSourceProcessLogMultiParticipantPacket.setData(IReplicationPacketData<?> mergedData)

Uses of IReplicationPacketData in com.gigaspaces.internal.cluster.node.impl.view

Methods in com.gigaspaces.internal.cluster.node.impl.view with parameters of type IReplicationPacketData

Modifier and Type	Method and Description
ReplicationChannelEntryDataFilterResult	ViewReplicationChannelDataFilter.filterBeforeReplicatingEntryData(IReplicationPacketEntryData entryData, PlatformLogicalVersion targetLogicalVersion, IReplicationPacketEntryDataContentExtractor contentExtractor, org.slf4j.Logger contextLogger, IReplicationPacketData data)