Modifier and Type | Class and Description |
---|---|
class |
ReplicationNode
The implementation of the
IReplicationNode interface |
Modifier and Type | Method and Description |
---|---|
IIncomingReplicationFacade |
IIncomingReplicationFacadeProvider.getIncomingReplicationFacade() |
IIncomingReplicationFacade |
LocalClusterReplicationSink.getIncomingReplicationFacade() |
Modifier and Type | Method and Description |
---|---|
QueryRemoteClusterTopologyResult |
QueryRemoteClusterTopologyPacket.accept(IIncomingReplicationFacade incomingReplicationFacade) |
SinkEstablishConnectionResult |
SinkEstablishConnectionPacket.accept(IIncomingReplicationFacade incomingReplicationFacade) |
Modifier and Type | Method and Description |
---|---|
ReliableAsyncMemberData |
FetchReliableAsyncMissingMemberDataPacket.accept(IIncomingReplicationFacade incomingReplicationFacade) |
Modifier and Type | Method and Description |
---|---|
Boolean |
CheckSourceChannelPacket.accept(IIncomingReplicationFacade replicationFacade) |
Object |
UnreliableOperationPacket.accept(IIncomingReplicationFacade incomingReplicationFacade) |
Object |
BatchReplicatedDataPacket.accept(IIncomingReplicationFacade replicationFacade) |
IProcessStatus |
GetProcessLogStatus.accept(IIncomingReplicationFacade incomingReplicationFacade) |
Object |
IdleStateDataReplicatedPacket.accept(IIncomingReplicationFacade incomingReplicationFacade) |
Object |
IterativeHandshakePacket.accept(IIncomingReplicationFacade incomingReplicationFacade) |
Object |
NextReplicaStatePacket.accept(IIncomingReplicationFacade incomingReplicationFacade) |
Object |
BatchReplicatedOneWayDataPacket.accept(IIncomingReplicationFacade replicationFacade) |
Object |
ReplicatedOneWayDataPacket.accept(IIncomingReplicationFacade incomingReplicationFacade) |
Collection<ISpaceReplicaData> |
ReplicaFetchDataPacket.accept(IIncomingReplicationFacade incomingReplicationFacade) |
Object |
ReplicaRequestPacket.accept(IIncomingReplicationFacade incomingReplicationFacade) |
Object |
ReliableAsyncStateUpdatePacket.accept(IIncomingReplicationFacade incomingReplicationFacade) |
ReplicationEndpointDetails |
FetchEndpointDetailsPacket.accept(IIncomingReplicationFacade incomingReplicationFacade) |
IDataConsumeFix |
HandleDataConsumeErrorPacket.accept(IIncomingReplicationFacade incomingReplicationFacade) |
Object |
PingPacket.accept(IIncomingReplicationFacade replicationFacade) |
Object |
ReplicatedDataPacket.accept(IIncomingReplicationFacade incomingReplicationFacade) |
Object |
ChannelBacklogDroppedPacket.accept(IIncomingReplicationFacade incomingReplicationFacade) |
Object |
ConnectChannelPacket.accept(IIncomingReplicationFacade replicationFacade) |
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 |
DirectPersistencyEntryReplicaData.execute(ISpaceReplicaConsumeFacade consumeFacade,
SpaceCopyIntermediateResult intermediateResult,
IIncomingReplicationFacade incomingReplicationFacade) |
void |
AbstractEntryReplicaData.execute(ISpaceReplicaConsumeFacade consumeFacade,
SpaceCopyIntermediateResult intermediateResult,
IIncomingReplicationFacade incomingReplicationFacade) |
void |
SpaceTypeReplicaData.execute(ISpaceReplicaConsumeFacade consumeFacade,
SpaceCopyIntermediateResult intermediateResult,
IIncomingReplicationFacade incomingReplicationFacade) |
void |
NotifyTemplateReplicaData.execute(ISpaceReplicaConsumeFacade consumeFacade,
SpaceCopyIntermediateResult intermediateResult,
IIncomingReplicationFacade incomingReplicationFacade) |
protected IMarker |
DirectPersistencyEntryReplicaData.getMarker(IIncomingReplicationFacade incomingReplicationFacade) |
protected IMarker |
EntryCopyReplicaData.getMarker(IIncomingReplicationFacade incomingReplicationFacade) |
protected abstract IMarker |
AbstractEntryReplicaData.getMarker(IIncomingReplicationFacade incomingReplicationFacade) |
protected IMarker |
EntrySynchronizeReplicaData.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.