Modifier and Type | Method and Description |
---|---|
Collection<ISpaceReplicaData> |
ReplicationNode.getNextReplicaBatch(Object context,
int fetchBatchSize) |
Modifier and Type | Method and Description |
---|---|
Collection<ISpaceReplicaData> |
ReplicaFetchDataPacket.accept(IIncomingReplicationFacade incomingReplicationFacade) |
Modifier and Type | Interface and Description |
---|---|
interface |
ISingleStageReplicaDataProducer<T extends ISpaceReplicaData> |
interface |
ISpaceReplicaDataConsumer<T extends ISpaceReplicaData,R extends ISpaceCopyIntermediateResult>
In charge of consuming in coming data generated by a space replica request
|
interface |
ISpaceReplicaDataProducer<T extends ISpaceReplicaData> |
interface |
ISpaceReplicaDataProducerBuilder<T extends ISpaceReplicaData> |
Modifier and Type | Interface and Description |
---|---|
interface |
IExecutableSpaceReplicaData |
Modifier and Type | Method and Description |
---|---|
Collection<ISpaceReplicaData> |
ReplicationNodeReplicaHandler.getNextReplicaBatch(Object context,
int batchSize) |
Collection<ISpaceReplicaData> |
IReplicaRequestFacade.getNextReplicaBatch(Object context,
int fetchBatchSize) |
Modifier and Type | Method and Description |
---|---|
boolean |
ISynchronizationCallback.synchronizationDataGenerated(ISpaceReplicaData data) |
Modifier and Type | Method and Description |
---|---|
void |
SpaceCopyReplicaRunnable.onResult(AsyncResult<Collection<ISpaceReplicaData>> result) |
Constructor and Description |
---|
ReplicationNodeReplicaHandler(ReplicationNode replicationNode,
ISpaceReplicaDataProducerBuilder<? extends ISpaceReplicaData> replicaDataProducerBuilder,
ISpaceCopyReplicaOutFilter outFilter) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractEntryReplicaData |
class |
AbstractReplicaData |
class |
DirectPersistencyEntryReplicaData |
class |
EntryCopyReplicaData |
class |
EntrySynchronizeReplicaData |
class |
NotifyTemplateReplicaData |
class |
SpaceTypeReplicaData |
Copyright © GigaSpaces.