Modifier and Type | Class and Description |
---|---|
class |
ReplicationNodeInFacade
A component that belongs to the
ReplicationNode that implements the IReplicationInFacade |
Modifier and Type | Method and Description |
---|---|
void |
DataTypeDropPacketData.execute(IReplicationInContext context,
IReplicationInFacade inReplicationHandler,
ReplicationPacketDataMediator dataMediator) |
void |
DataTypeAddIndexPacketData.execute(IReplicationInContext context,
IReplicationInFacade inReplicationHandler,
ReplicationPacketDataMediator dataMediator) |
void |
DataTypeIntroducePacketData.execute(IReplicationInContext context,
IReplicationInFacade inReplicationHandler,
ReplicationPacketDataMediator dataMediator) |
void |
NotificationSentSyncOperation.execute(String sourceMemberLookupName,
IReplicationInFacade replicationInFacade) |
Modifier and Type | Method and Description |
---|---|
IReplicationInFacade |
AbstractReplicationTargetGroup.getReplicationInFacade() |
Modifier and Type | Method and Description |
---|---|
IReplicationTargetGroup |
IReplicationDynamicTargetGroupBuilder.createDynamicGroup(String groupName,
IReplicationRouter replicationRouter,
IReplicationInFacade replicationInFacade,
IReplicationProcessLogExceptionHandlerBuilder exceptionHandlerBuilder,
IReplicationInFilter inFilter,
IReplicationTargetGroupStateListener stateListener) |
IReplicationTargetGroup |
IReplicationStaticTargetGroupBuilder.createStaticGroup(IReplicationRouter replicationRouter,
IReplicationInFacade replicationInFacade,
IReplicationProcessLogExceptionHandlerBuilder exceptionHandlerBuilder,
IReplicationInFilter inFilter,
IReplicationTargetGroupStateListener stateListener) |
void |
IReplicationUnreliableOperation.execute(String sourceMemberLookupName,
IReplicationInFacade replicationInFacade) |
Constructor and Description |
---|
AbstractReplicationTargetGroup(TargetGroupConfig groupConfig,
IReplicationRouter replicationRouter,
IReplicationInFacade replicationInFacade,
IReplicationInFilter inFilter,
IReplicationTargetGroupStateListener stateListener) |
Modifier and Type | Method and Description |
---|---|
IDataConsumeResult |
ReplicationPacketDataConsumer.consume(IReplicationInContext context,
IExecutableReplicationPacketData<?> data,
IReplicationInFacade replicationInFacade,
IReplicationInFilterCallback inFilterCallback) |
IDataConsumeResult |
BlobstoreReplicationPacketDataConsumer.consume(IReplicationInContext context,
IExecutableReplicationPacketData<?> data,
IReplicationInFacade replicationInFacade,
IReplicationInFilterCallback inFilterCallback) |
IDataConsumeResult |
IReplicationPacketDataConsumer.consume(IReplicationInContext context,
T data,
IReplicationInFacade replicationInFacade,
IReplicationInFilterCallback filterInCallback)
Consumes a
IReplicationPacketData and delegate the operation is represents to the
corresponding method at the given IReplicationInFacade |
IDataConsumeResult |
ReplicationPacketDataConsumer.consumePendingPackets(IReplicationInBatchContext context,
IReplicationInFacade replicationInFacade) |
IDataConsumeResult |
IReplicationPacketDataBatchConsumer.consumePendingPackets(IReplicationInBatchContext batchContext,
IReplicationInFacade replicationInFacade)
Consume packets which are pending in the provided batch context.
|
void |
DiscardReplicationPacketData.execute(IReplicationInContext context,
IReplicationInFacade inReplicationHandler,
ReplicationPacketDataMediator dataMediator) |
void |
IExecutableReplicationPacketData.execute(IReplicationInContext context,
IReplicationInFacade inReplicationHandler,
ReplicationPacketDataMediator dataMediator) |
Modifier and Type | Method and Description |
---|---|
void |
EntryLeaseExpiredFullReplicationPacketData.execute(IReplicationInContext context,
IReplicationInFacade inReplicationHandler,
ReplicationPacketDataMediator dataMediator) |
void |
PartialUpdateReplicationPacketData.execute(IReplicationInContext context,
IReplicationInFacade inReplicationHandler,
ReplicationPacketDataMediator dataMediator) |
void |
RemoveReplicationPacketData.execute(IReplicationInContext context,
IReplicationInFacade inReplicationHandler,
ReplicationPacketDataMediator dataMediator) |
void |
TransactionAbortReplicationPacketData.execute(IReplicationInContext context,
IReplicationInFacade inReplicationHandler,
ReplicationPacketDataMediator dataMediator) |
void |
TransactionOnePhaseReplicationPacketData.execute(IReplicationInContext context,
IReplicationInFacade inReplicationHandler,
ReplicationPacketDataMediator dataMediator) |
void |
UpdateReplicationPacketData.execute(IReplicationInContext context,
IReplicationInFacade inReplicationHandler,
ReplicationPacketDataMediator dataMediator) |
void |
SingleUidReplicationPacketData.execute(IReplicationInContext context,
IReplicationInFacade inReplicationHandler,
ReplicationPacketDataMediator dataMediator) |
void |
TransactionPrepareReplicationPacketData.execute(IReplicationInContext context,
IReplicationInFacade inReplicationHandler,
ReplicationPacketDataMediator dataMediator) |
void |
WriteReplicationPacketData.execute(IReplicationInContext context,
IReplicationInFacade inReplicationHandler,
ReplicationPacketDataMediator dataMediator) |
void |
CancelLeaseFullReplicationPacketData.execute(IReplicationInContext context,
IReplicationInFacade inReplicationHandler,
ReplicationPacketDataMediator dataMediator) |
void |
InsertNotifyTemplateReplicationPacketData.execute(IReplicationInContext context,
IReplicationInFacade inReplicationHandler,
ReplicationPacketDataMediator dataMediator) |
void |
TransactionCommitReplicationPacketData.execute(IReplicationInContext context,
IReplicationInFacade inReplicationHandler,
ReplicationPacketDataMediator dataMediator) |
void |
TransactionReplicationPacketData.execute(IReplicationInContext context,
IReplicationInFacade inReplicationHandler,
ReplicationPacketDataMediator dataMediator)
Deprecated.
|
protected void |
EvictReplicationPacketData.executeImpl(IReplicationInContext context,
IReplicationInFacade inReplicationHandler) |
protected void |
ExtendNotifyTemplateLeaseReplicationPacketData.executeImpl(IReplicationInContext context,
IReplicationInFacade inReplicationHandler) |
protected void |
EntryLeaseExpiredReplicationPacketData.executeImpl(IReplicationInContext context,
IReplicationInFacade inReplicationHandler) |
protected void |
ExtendEntryLeaseReplicationPacketData.executeImpl(IReplicationInContext context,
IReplicationInFacade inReplicationHandler) |
protected void |
NotifyTemplateLeaseExpiredReplicationPacketData.executeImpl(IReplicationInContext context,
IReplicationInFacade inReplicationHandler) |
protected void |
RemoveNotifyTemplateReplicationPacketData.executeImpl(IReplicationInContext context,
IReplicationInFacade inReplicationHandler) |
protected abstract void |
SingleUidReplicationPacketData.executeImpl(IReplicationInContext context,
IReplicationInFacade inReplicationHandler) |
protected void |
CancelLeaseReplicationPacketData.executeImpl(IReplicationInContext context,
IReplicationInFacade inReplicationHandler) |
protected void |
ChangeReplicationPacketData.executeImpl(IReplicationInContext context,
IReplicationInFacade inReplicationHandler) |
protected void |
RemoveByUIDReplicationPacketData.executeImpl(IReplicationInContext context,
IReplicationInFacade inReplicationHandler) |
Modifier and Type | Method and Description |
---|---|
IReplicationInFacade |
AbstractSingleFileTargetProcessLog.getReplicationInFacade() |
Constructor and Description |
---|
AbstractSingleFileTargetProcessLog(IReplicationPacketDataConsumer dataConsumer,
IReplicationProcessLogExceptionHandler exceptionHandler,
IReplicationInFacade replicationInFacade,
String name,
String groupName,
String sourceLookupName,
IReplicationGroupHistory groupHistory) |
Modifier and Type | Method and Description |
---|---|
IReplicationAsyncTargetProcessLog |
IReplicationAsyncProcessLogBuilder.createAsyncProcessLog(TargetGroupConfig groupConfig,
IReplicationInFacade replicationInFacade,
IReplicationProcessLogExceptionHandler exceptionHandler,
String myLookupName,
String groupName,
String sourceLookupName,
IReplicationGroupHistory groupHistory) |
IReplicationBatchConsumeAsyncTargetProcessLog |
IReplicationAsyncProcessLogBuilder.createBatchConsumeAsyncProcessLog(TargetGroupConfig groupConfig,
IBacklogHandshakeRequest handshakeRequest,
IReplicationInFacade replicationInFacade,
IReplicationProcessLogExceptionHandler exceptionHandler,
String myLookupName,
String groupNameString,
String sourceLookupName,
IReplicationGroupHistory groupHistory) |
Modifier and Type | Method and Description |
---|---|
IReplicationSyncTargetProcessLog |
IReplicationSyncProcessLogBuilder.createSyncProcessLog(TargetGroupConfig groupConfig,
IReplicationInFacade replicationInFacade,
IReplicationProcessLogExceptionHandler exceptionHandler,
String myLookupName,
String groupName,
String sourceLookupName,
IReplicationGroupHistory groupHistory) |
Copyright © GigaSpaces.