Uses of Interface
com.gigaspaces.internal.cluster.node.impl.packets.data.IReplicationPacketData
Packages that use IReplicationPacketData
Package
Description
-
Uses of IReplicationPacketData in com.gigaspaces.internal.cluster.node.impl
Classes in com.gigaspaces.internal.cluster.node.impl that implement IReplicationPacketDataModifier and TypeClassDescriptionclassclassclass -
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 IReplicationPacketDataMethods in com.gigaspaces.internal.cluster.node.impl.backlog with parameters of type IReplicationPacketDataModifier and TypeMethodDescriptionintAccumulatedBacklogWeightPolicy.calculateWeight(IReplicationPacketData<?> data) intBacklogWeightPolicy.calculateWeight(IReplicationPacketData<?> data) intFixedBacklogWeightPolicy.calculateWeight(IReplicationPacketData<?> data) protected voidAbstractSingleFileGroupBacklog.ensureLimit(IReplicationPacketData<?> data) protected voidAbstractSingleFileGroupBacklog.setPacketWeight(IReplicationPacketData<?> data) protected booleanAbstractSingleFileGroupBacklog.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 IReplicationPacketDataModifier and TypeMethodDescriptionGlobalOrderDeletedBacklogPacket.getData()GlobalOrderDiscardedReplicationPacket.getData()GlobalOrderOperationPacket.getData()GlobalOrderReliableAsyncKeptDiscardedOrderedPacket.getData()Methods in com.gigaspaces.internal.cluster.node.impl.backlog.globalorder with parameters of type IReplicationPacketDataModifier and TypeMethodDescriptionGlobalOrderDeletedBacklogPacket.cloneWithNewData(IReplicationPacketData<?> newData) GlobalOrderDiscardedReplicationPacket.cloneWithNewData(IReplicationPacketData<?> newData) GlobalOrderOperationPacket.cloneWithNewData(IReplicationPacketData<?> newData) GlobalOrderReliableAsyncKeptDiscardedOrderedPacket.cloneWithNewData(IReplicationPacketData<?> newData) Constructors in com.gigaspaces.internal.cluster.node.impl.backlog.globalorder with parameters of type IReplicationPacketData -
Uses of IReplicationPacketData in com.gigaspaces.internal.cluster.node.impl.backlog.multibucketsinglefile
Methods in com.gigaspaces.internal.cluster.node.impl.backlog.multibucketsinglefile that return IReplicationPacketDataModifier and TypeMethodDescriptionDeletedMultiBucketOrderedPacket.getData()DiscardedMultiBucketOrderedPacket.getData()DiscardedSingleBucketOrderedPacket.getData()MultiBucketSingleFileReliableAsyncKeptDiscardedPacket.getData()MultipleBucketOrderedPacket.getData()SingleBucketOrderedPacket.getData()Methods in com.gigaspaces.internal.cluster.node.impl.backlog.multibucketsinglefile with parameters of type IReplicationPacketDataModifier and TypeMethodDescriptionDeletedMultiBucketOrderedPacket.cloneWithNewData(IReplicationPacketData<?> newData) DiscardedMultiBucketOrderedPacket.cloneWithNewData(IReplicationPacketData<?> newData) DiscardedSingleBucketOrderedPacket.cloneWithNewData(IReplicationPacketData<?> newData) IMultiBucketSingleFileReplicationOrderedPacket.cloneWithNewData(IReplicationPacketData<?> newData) MultiBucketSingleFileReliableAsyncKeptDiscardedPacket.cloneWithNewData(IReplicationPacketData<?> newData) MultipleBucketOrderedPacket.cloneWithNewData(IReplicationPacketData<?> newData) SingleBucketOrderedPacket.cloneWithNewData(IReplicationPacketData<?> newData) Constructors in com.gigaspaces.internal.cluster.node.impl.backlog.multibucketsinglefile with parameters of type IReplicationPacketDataModifierConstructorDescriptionMultipleBucketOrderedPacket(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 IReplicationPacketDataModifier and TypeMethodDescriptionvoidIReplicationInFilterCallback.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 IReplicationPacketDataModifier and TypeMethodDescriptionGeneralReplicationChannelDataFilter.filterBeforeReplicatingData(IReplicationPacketData<?> data, PlatformLogicalVersion targetLogicalVersion, org.slf4j.Logger contextLogger) IReplicationChannelDataFilter.filterBeforeReplicatingData(IReplicationPacketData<?> data, PlatformLogicalVersion targetLogicalVersion, org.slf4j.Logger contextLogger) Specifies whether the given data should pass the filter as is, be converted or removedGeneralReplicationChannelDataFilter.filterBeforeReplicatingEntryData(IReplicationPacketEntryData entryData, PlatformLogicalVersion targetLogicalVersion, IReplicationPacketEntryDataContentExtractor contentExtractor, org.slf4j.Logger contextLogger, IReplicationPacketData data) 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 removedReliableAsyncKeeperLruCentralDataSourceReplicationChannelDataFilter.filterBeforeReplicatingEntryData(IReplicationPacketEntryData entryData, PlatformLogicalVersion targetLogicalVersion, IReplicationPacketEntryDataContentExtractor contentExtractor, org.slf4j.Logger contextLogger, IReplicationPacketData data) voidAbstractReplicationTargetChannel.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 IReplicationPacketDataModifier and TypeMethodDescriptionGatewayChannelDataFilter.filterBeforeReplicatingData(IReplicationPacketData<?> data, PlatformLogicalVersion targetLogicalVersion, org.slf4j.Logger contextLogger) ReliableAsyncChannelDataFilter.filterBeforeReplicatingData(IReplicationPacketData<?> data, PlatformLogicalVersion targetLogicalVersion, org.slf4j.Logger contextLogger) GatewayChannelDataFilter.filterBeforeReplicatingEntryData(IReplicationPacketEntryData entryData, PlatformLogicalVersion targetLogicalVersion, IReplicationPacketEntryDataContentExtractor contentExtractor, org.slf4j.Logger contextLogger, IReplicationPacketData data) MirrorChannelDataFilter.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 IReplicationPacketDataModifier and TypeMethodDescriptionNotificationReplicationChannelDataFilter.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 IReplicationPacketDataMethods in com.gigaspaces.internal.cluster.node.impl.packets with parameters of type IReplicationPacketDataModifier and TypeMethodDescriptionIReplicationOrderedPacket.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 IReplicationPacketDataModifier and TypeInterfaceDescriptioninterfaceIReplicationPacketDataBatchConsumer<T extends IReplicationPacketData<?>>interfaceIReplicationPacketDataConsumer<T extends IReplicationPacketData<?>>ConsumesIReplicationPacketDataand delegate it to the corresponding replication in handler.interfaceIReplicationPacketDataProducer<T extends IReplicationPacketData<?>>Convert logical operation to a representingIReplicationPacketDataSubinterfaces of IReplicationPacketData in com.gigaspaces.internal.cluster.node.impl.packets.dataModifier and TypeInterfaceDescriptioninterfaceAn extension ofIReplicationPacketDatathat can be self executed.Classes in com.gigaspaces.internal.cluster.node.impl.packets.data that implement IReplicationPacketDataMethods in com.gigaspaces.internal.cluster.node.impl.packets.data that return IReplicationPacketDataModifier and TypeMethodDescriptionIReplicationPacketData.clone()IReplicationPacketDataConsumer.merge(IReplicationPacketData<?>[] allParticipantsData, IReplicationParticipantsMetadata participantsMetadata) Merges data of multiple participants operations to a single operation data which will eventually be executed as one.ReplicationPacketDataConsumer.merge(IReplicationPacketData<?>[] allParticipantsData, IReplicationParticipantsMetadata participantsMetadata) Methods in com.gigaspaces.internal.cluster.node.impl.packets.data with parameters of type IReplicationPacketDataModifier and TypeMethodDescriptionIReplicationPacketDataConsumer.extractParticipantsMetadata(IReplicationPacketData<?> data) Extracts participants meta data for the provided replication packet dataReplicationPacketDataConsumer.extractParticipantsMetadata(IReplicationPacketData<?> data) IReplicationPacketDataConsumer.merge(IReplicationPacketData<?>[] allParticipantsData, IReplicationParticipantsMetadata participantsMetadata) Merges data of multiple participants operations to a single operation data which will eventually be executed as one.ReplicationPacketDataConsumer.merge(IReplicationPacketData<?>[] allParticipantsData, IReplicationParticipantsMetadata participantsMetadata) IReplicationPacketDataConsumer.toFilterEntries(IReplicationInContext context, IReplicationPacketData<?> data) Transform generated data to filter entry in order to be passed to a filterReplicationPacketDataConsumer.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 IReplicationPacketDataModifier and TypeClassDescriptionclassBase class for replication packets that depend on a previousTransactionPrepareReplicationPacketDataoccurringclassA base class forIReplicationPacketDataimplementations that contains only oneIReplicationPacketEntryDataclassBase class for transaction replication packet dataclassclassclassclassclassclassclassclassclassclassclassclassclassclassclassclassclassReplication packet representing transaction abortclassReplication packet representing transaction commitclassReplication packet representing a one phase commit transactionclassReplication packet representing transaction prepareclassDeprecated.classclass -
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 IReplicationPacketDataModifier and TypeMethodDescription<T extends IReplicationPacketData<?>>
IReplicationPacketDataConsumer<T>AbstractSingleFileTargetProcessLog.getDataConsumer()<T extends IReplicationPacketData<?>>
IReplicationPacketDataConsumer<T>IReplicationTargetProcessLog.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 IReplicationPacketDataModifier and TypeMethodDescriptionIReplicationParticipantsMediator.getAllParticipantsData(MultiSourceProcessLogPacket packet) Gets all data for a multiple participants replication operation.ReplicationParticipantsMediator.getAllParticipantsData(MultiSourceProcessLogPacket packet) MultiSourceProcessLogMultiParticipantPacket.getData()MultiSourceProcessLogPacket.getData()Methods in com.gigaspaces.internal.cluster.node.impl.processlog.multisourcesinglefile with parameters of type IReplicationPacketDataModifier and TypeMethodDescriptionvoidMultiSourceProcessLogMultiParticipantPacket.setData(IReplicationPacketData<?> mergedData) voidMultiSourceProcessLogPacket.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 IReplicationPacketDataModifier and TypeMethodDescriptionViewReplicationChannelDataFilter.filterBeforeReplicatingEntryData(IReplicationPacketEntryData entryData, PlatformLogicalVersion targetLogicalVersion, IReplicationPacketEntryDataContentExtractor contentExtractor, org.slf4j.Logger contextLogger, IReplicationPacketData data)
TransactionOnePhaseReplicationPacketData