com.gigaspaces.internal.cluster.node.impl.packets.data

Interface IReplicationPacketData<T extends IReplicationPacketEntryData>

All Superinterfaces:

Cloneable, Collection<T>, Externalizable, ISwapExternalizable, Iterable<T>, Serializable, SmartExternalizable

All Known Subinterfaces:

IExecutableReplicationPacketData<T>

All Known Implementing Classes:

AbstractPrepareDependentTransactionReplicationPacketData, AbstractReplicationPacketSingleEntryData, AbstractTransactionReplicationPacketData, CancelLeaseFullReplicationPacketData, CancelLeaseReplicationPacketData, ChangeReplicationPacketData, DataTypeAddIndexPacketData, DataTypeDropPacketData, DataTypeIntroducePacketData, DiscardReplicationPacketData, EntryLeaseExpiredFullReplicationPacketData, EntryLeaseExpiredReplicationPacketData, EvictReplicationPacketData, ExtendEntryLeaseReplicationPacketData, ExtendNotifyTemplateLeaseReplicationPacketData, InsertNotifyTemplateReplicationPacketData, NotifyTemplateLeaseExpiredReplicationPacketData, PartialUpdateReplicationPacketData, RemoveByUIDReplicationPacketData, RemoveNotifyTemplateReplicationPacketData, RemoveReplicationPacketData, SingleReplicationPacketData, SingleUidReplicationPacketData, TransactionAbortReplicationPacketData, TransactionCommitReplicationPacketData, TransactionOnePhaseReplicationPacketData, TransactionPrepareReplicationPacketData, TransactionReplicationPacketData, UpdateReplicationPacketData, WriteReplicationPacketData

public interface IReplicationPacketData<T extends IReplicationPacketEntryData>
extends Collection<T>, SmartExternalizable, Cloneable, ISwapExternalizable

The replication packet data that is kept in side an IReplicationOrderedPacket which contains the data needed for the processing of the packet

Since:

8.0

Author:

eitany

Method Summary

Modifier and Type	Method and Description
boolean	beforeDelayedReplication() If the replication of this packet is delayed due to being asynchronous by nature or the target was disconnected when the replication packet was generated, this method is called before the actual replication and the implementor can modify the packet accordingly, mostly relevant for time to live update.
IReplicationPacketData<T>	clone()
ReplicationMultipleOperationType	getMultipleOperationType()
Object	getRecoveryFilteringId()
IReplicationPacketEntryData	getSingleEntryData()
int	getWeight()
boolean	isFromGateway()
boolean	isMultiParticipantData() Gets whether this data is part of multiple participants data
boolean	isSingleEntryData()
boolean	requiresRecoveryFiltering()
void	setWeight(int weight)
boolean	supportsReplicationFilter()

Methods inherited from interface java.util.Collection

add, addAll, clear, contains, containsAll, equals, hashCode, isEmpty, iterator, parallelStream, remove, removeAll, removeIf, retainAll, size, spliterator, stream, toArray, toArray

Methods inherited from interface java.lang.Iterable

forEach

Methods inherited from interface com.gigaspaces.serialization.SmartExternalizable

enabledSmartExternalizableWithReference

Methods inherited from interface java.io.Externalizable

readExternal, writeExternal

Methods inherited from interface com.gigaspaces.internal.server.space.redolog.storage.bytebuffer.ISwapExternalizable

readFromSwap, writeToSwap

Method Detail

clone

IReplicationPacketData<T> clone()

beforeDelayedReplication

boolean beforeDelayedReplication()

If the replication of this packet is delayed due to being asynchronous by nature or the target was disconnected when the replication packet was generated, this method is called before the actual replication and the implementor can modify the packet accordingly, mostly relevant for time to live update. If the method returns false the packet is no longer relevant and it is discarded

isSingleEntryData

boolean isSingleEntryData()

getSingleEntryData

IReplicationPacketEntryData getSingleEntryData()

supportsReplicationFilter

boolean supportsReplicationFilter()

isMultiParticipantData

boolean isMultiParticipantData()

Gets whether this data is part of multiple participants data

getMultipleOperationType

ReplicationMultipleOperationType getMultipleOperationType()

requiresRecoveryFiltering

boolean requiresRecoveryFiltering()

getRecoveryFilteringId

Object getRecoveryFilteringId()

isFromGateway

boolean isFromGateway()

Returns:

Gets whether this packet was received from gateway replication

setWeight

void setWeight(int weight)

getWeight

int getWeight()