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

Interface IReplicationTargetProcessLog

All Known Subinterfaces:

IMultiBucketSingleFileProcessLog, IReplicationAsyncTargetProcessLog, IReplicationBatchConsumeAsyncTargetProcessLog, IReplicationReliableAsyncTargetProcessLog, IReplicationSyncTargetProcessLog

All Known Implementing Classes:

AbstractGlobalOrderTargetProcessLog, AbstractMultiBucketSingleFileTargetProcessLog, GlobalOrderBatchConsumeTargetProcessLog, GlobalOrderReliableAsyncTargetKeeperProcessLog, GlobalOrderReliableAsyncTargetProcessLog, GlobalOrderTargetProcessLog, MultiBucketSingleFileBatchConsumeTargetProcessLog, MultiBucketSingleFileReliableAsyncTargetKeeperProcessLog, MultiBucketSingleFileReliableAsyncTargetProcessLog, MultiBucketSingleFileSyncTargetProcessLog, MultiSourceSingleFileReliableAsyncTargetKeeperProcessLog, MultiSourceSingleFileReliableAsyncTargetProcessLog

public interface IReplicationTargetProcessLog

Method Summary

Modifier and Type	Method and Description
boolean	close(long time, TimeUnit unit)
String	dumpState()
<T extends IReplicationPacketData<?>> IReplicationPacketDataConsumer<T>	getDataConsumer()
IProcessLogHandshakeResponse	performHandshake(String memberName, IBacklogHandshakeRequest handshakeRequest)
IProcessResult	process(String sourceLookupName, IReplicationOrderedPacket packet, IReplicationInFilterCallback inFilterCallback)
IProcessResult	processBatch(String sourceLookupName, List<IReplicationOrderedPacket> packet, IReplicationInFilterCallback inFilterCallback)
void	processHandshakeIteration(String sourceMemberName, IHandshakeIteration handshakeIteration)
IProcessResult	processIdleStateData(String sourceLookupName, IIdleStateData idleStateData, IReplicationInFilterCallback inFilterCallback)
IProcessLogHandshakeResponse	resync(IBacklogHandshakeRequest handshakeRequest)
String	toLogMessage()
Object	toWireForm(IProcessResult processResult)

Method Detail

performHandshake

IProcessLogHandshakeResponse performHandshake(String memberName,
                                              IBacklogHandshakeRequest handshakeRequest)
                                       throws IncomingReplicationOutOfSyncException

Throws:

IncomingReplicationOutOfSyncException

processBatch

IProcessResult processBatch(String sourceLookupName,
                            List<IReplicationOrderedPacket> packet,
                            IReplicationInFilterCallback inFilterCallback)

process

IProcessResult process(String sourceLookupName,
                       IReplicationOrderedPacket packet,
                       IReplicationInFilterCallback inFilterCallback)

close

boolean close(long time,
              TimeUnit unit)
       throws InterruptedException

Throws:

InterruptedException

getDataConsumer

<T extends IReplicationPacketData<?>> IReplicationPacketDataConsumer<T> getDataConsumer()

processHandshakeIteration

void processHandshakeIteration(String sourceMemberName,
                               IHandshakeIteration handshakeIteration)

resync

IProcessLogHandshakeResponse resync(IBacklogHandshakeRequest handshakeRequest)

dumpState

String dumpState()

toWireForm

Object toWireForm(IProcessResult processResult)

toLogMessage

String toLogMessage()

processIdleStateData

IProcessResult processIdleStateData(String sourceLookupName,
                                    IIdleStateData idleStateData,
                                    IReplicationInFilterCallback inFilterCallback)