com.gigaspaces.internal.cluster.node.impl.processlog.multibucketsinglefile

Interface IMultiBucketSingleFileProcessLog

All Superinterfaces:

IReplicationTargetProcessLog

All Known Implementing Classes:

AbstractMultiBucketSingleFileTargetProcessLog, MultiBucketSingleFileBatchConsumeTargetProcessLog, MultiBucketSingleFileReliableAsyncTargetKeeperProcessLog, MultiBucketSingleFileReliableAsyncTargetProcessLog, MultiBucketSingleFileSyncTargetProcessLog

public interface IMultiBucketSingleFileProcessLog
extends IReplicationTargetProcessLog

Method Summary

Modifier and Type	Method and Description
MultiBucketSingleFileProcessResult	process(String sourceLookupName, DeletedMultiBucketOrderedPacket packet, IReplicationInFilterCallback inFilterCallback, ParallelBatchProcessingContext batchContext, int segmentIndex)
MultiBucketSingleFileProcessResult	process(String sourceLookupName, DiscardedMultiBucketOrderedPacket packet, IReplicationInFilterCallback inFilterCallback, ParallelBatchProcessingContext batchContext, int segmentIndex)
MultiBucketSingleFileProcessResult	process(String sourceLookupName, ISingleBucketReplicationOrderedPacket packet, IReplicationInFilterCallback inFilterCallback, ParallelBatchProcessingContext batchContext, int segmentIndex)
MultiBucketSingleFileProcessResult	process(String sourceLookupName, MultipleBucketOrderedPacket packet, IReplicationInFilterCallback inFilterCallback, ParallelBatchProcessingContext batchContext, int segmentIndex)

Methods inherited from interface com.gigaspaces.internal.cluster.node.impl.processlog.IReplicationTargetProcessLog

close, dumpState, getDataConsumer, performHandshake, process, processBatch, processHandshakeIteration, processIdleStateData, resync, toLogMessage, toWireForm

Method Detail

process

MultiBucketSingleFileProcessResult process(String sourceLookupName,
                                           ISingleBucketReplicationOrderedPacket packet,
                                           IReplicationInFilterCallback inFilterCallback,
                                           ParallelBatchProcessingContext batchContext,
                                           int segmentIndex)

process

MultiBucketSingleFileProcessResult process(String sourceLookupName,
                                           MultipleBucketOrderedPacket packet,
                                           IReplicationInFilterCallback inFilterCallback,
                                           ParallelBatchProcessingContext batchContext,
                                           int segmentIndex)

process

MultiBucketSingleFileProcessResult process(String sourceLookupName,
                                           DiscardedMultiBucketOrderedPacket packet,
                                           IReplicationInFilterCallback inFilterCallback,
                                           ParallelBatchProcessingContext batchContext,
                                           int segmentIndex)

process

MultiBucketSingleFileProcessResult process(String sourceLookupName,
                                           DeletedMultiBucketOrderedPacket packet,
                                           IReplicationInFilterCallback inFilterCallback,
                                           ParallelBatchProcessingContext batchContext,
                                           int segmentIndex)