| Modifier and Type | Class and Description | 
|---|---|
class  | 
ReplicationNode
The implementation of the  
IReplicationNode interface | 
| Modifier and Type | Method and Description | 
|---|---|
IIncomingReplicationFacade | 
LocalClusterReplicationSink.getIncomingReplicationFacade()  | 
IIncomingReplicationFacade | 
IIncomingReplicationFacadeProvider.getIncomingReplicationFacade()  | 
| Modifier and Type | Method and Description | 
|---|---|
SinkEstablishConnectionResult | 
SinkEstablishConnectionPacket.accept(IIncomingReplicationFacade incomingReplicationFacade)  | 
QueryRemoteClusterTopologyResult | 
QueryRemoteClusterTopologyPacket.accept(IIncomingReplicationFacade incomingReplicationFacade)  | 
| Modifier and Type | Method and Description | 
|---|---|
ReliableAsyncMemberData | 
FetchReliableAsyncMissingMemberDataPacket.accept(IIncomingReplicationFacade incomingReplicationFacade)  | 
| Modifier and Type | Method and Description | 
|---|---|
Object | 
ConnectChannelPacket.accept(IIncomingReplicationFacade replicationFacade)  | 
Object | 
ReliableAsyncStateUpdatePacket.accept(IIncomingReplicationFacade incomingReplicationFacade)  | 
Object | 
NextReplicaStatePacket.accept(IIncomingReplicationFacade incomingReplicationFacade)  | 
Object | 
BatchReplicatedOneWayDataPacket.accept(IIncomingReplicationFacade replicationFacade)  | 
Boolean | 
CheckSourceChannelPacket.accept(IIncomingReplicationFacade replicationFacade)  | 
Object | 
IterativeHandshakePacket.accept(IIncomingReplicationFacade incomingReplicationFacade)  | 
IDataConsumeFix | 
HandleDataConsumeErrorPacket.accept(IIncomingReplicationFacade incomingReplicationFacade)  | 
Object | 
ReplicaRequestPacket.accept(IIncomingReplicationFacade incomingReplicationFacade)  | 
Object | 
ChannelBacklogDroppedPacket.accept(IIncomingReplicationFacade incomingReplicationFacade)  | 
Object | 
BatchReplicatedDataPacket.accept(IIncomingReplicationFacade replicationFacade)  | 
Collection<ISpaceReplicaData> | 
ReplicaFetchDataPacket.accept(IIncomingReplicationFacade incomingReplicationFacade)  | 
Object | 
ReplicatedOneWayDataPacket.accept(IIncomingReplicationFacade incomingReplicationFacade)  | 
Object | 
PingPacket.accept(IIncomingReplicationFacade replicationFacade)  | 
Object | 
UnreliableOperationPacket.accept(IIncomingReplicationFacade incomingReplicationFacade)  | 
IProcessStatus | 
GetProcessLogStatus.accept(IIncomingReplicationFacade incomingReplicationFacade)  | 
Object | 
ReplicatedDataPacket.accept(IIncomingReplicationFacade incomingReplicationFacade)  | 
Object | 
IdleStateDataReplicatedPacket.accept(IIncomingReplicationFacade incomingReplicationFacade)  | 
ReplicationEndpointDetails | 
FetchEndpointDetailsPacket.accept(IIncomingReplicationFacade incomingReplicationFacade)  | 
| Modifier and Type | Method and Description | 
|---|---|
Object | 
SynchronizationDonePacket.accept(IIncomingReplicationFacade incomingReplicationFacade)  | 
void | 
SpaceReplicaDataConsumer.consumeData(IExecutableSpaceReplicaData data,
           SpaceCopyIntermediateResult intermediateResult,
           IIncomingReplicationFacade facade)  | 
void | 
ISpaceReplicaDataConsumer.consumeData(T data,
           R intermediateResult,
           IIncomingReplicationFacade incomingReplicationFacade)
consumes one  
ISpaceReplicaData. | 
void | 
IExecutableSpaceReplicaData.execute(ISpaceReplicaConsumeFacade consumeFacade,
       SpaceCopyIntermediateResult intermediateResult,
       IIncomingReplicationFacade incomingReplicationFacade)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
NotifyTemplateReplicaData.execute(ISpaceReplicaConsumeFacade consumeFacade,
       SpaceCopyIntermediateResult intermediateResult,
       IIncomingReplicationFacade incomingReplicationFacade)  | 
void | 
SpaceTypeReplicaData.execute(ISpaceReplicaConsumeFacade consumeFacade,
       SpaceCopyIntermediateResult intermediateResult,
       IIncomingReplicationFacade incomingReplicationFacade)  | 
void | 
DirectPersistencyEntryReplicaData.execute(ISpaceReplicaConsumeFacade consumeFacade,
       SpaceCopyIntermediateResult intermediateResult,
       IIncomingReplicationFacade incomingReplicationFacade)  | 
void | 
AbstractEntryReplicaData.execute(ISpaceReplicaConsumeFacade consumeFacade,
       SpaceCopyIntermediateResult intermediateResult,
       IIncomingReplicationFacade incomingReplicationFacade)  | 
protected IMarker | 
EntrySynchronizeReplicaData.getMarker(IIncomingReplicationFacade incomingReplicationFacade)  | 
protected IMarker | 
EntryCopyReplicaData.getMarker(IIncomingReplicationFacade incomingReplicationFacade)  | 
protected IMarker | 
DirectPersistencyEntryReplicaData.getMarker(IIncomingReplicationFacade incomingReplicationFacade)  | 
protected abstract IMarker | 
AbstractEntryReplicaData.getMarker(IIncomingReplicationFacade incomingReplicationFacade)  | 
| Modifier and Type | Method and Description | 
|---|---|
abstract T | 
AbstractReplicationPacket.accept(IIncomingReplicationFacade incomingReplicationFacade)
Process the replication packet at the target side. 
 | 
protected IReplicationTargetGroup | 
AbstractGroupNameReplicationPacket.getTargetGroup(IIncomingReplicationFacade incomingReplicationFacade)  | 
Copyright © GigaSpaces.