Modifier and Type | Method and Description |
---|---|
IBacklogHandshakeRequest |
IReplicationGroupBacklog.getHandshakeRequest(String memberName,
Object customBacklogMetadata) |
Modifier and Type | Method and Description |
---|---|
IHandshakeContext |
IReplicationGroupBacklog.processHandshakeResponse(String memberName,
IBacklogHandshakeRequest request,
IProcessLogHandshakeResponse response,
PlatformLogicalVersion targetLogicalVersion,
Object customBacklogMetadata) |
Modifier and Type | Class and Description |
---|---|
class |
GlobalOrderBacklogHandshakeRequest |
class |
GlobalOrderReliableAsyncBacklogHandshakeRequest |
Modifier and Type | Method and Description |
---|---|
IHandshakeContext |
AbstractGlobalOrderGroupBacklog.processHandshakeResponse(String memberName,
IBacklogHandshakeRequest request,
IProcessLogHandshakeResponse response,
PlatformLogicalVersion targetLogicalVersion,
Object customBacklogMetadata) |
IHandshakeContext |
GlobalOrderReliableAsyncGroupBacklog.processHandshakeResponse(String memberName,
IBacklogHandshakeRequest request,
IProcessLogHandshakeResponse response,
PlatformLogicalVersion targetLogicalVersion,
Object customBacklogMetadata) |
Modifier and Type | Class and Description |
---|---|
class |
MultiBucketSingleFileHandshakeRequest |
class |
MultiBucketSingleFileReliableAsyncHandshakeRequest |
Modifier and Type | Method and Description |
---|---|
IHandshakeContext |
MultiBucketSingleFileReliableAsyncGroupBacklog.processHandshakeResponse(String memberName,
IBacklogHandshakeRequest request,
IProcessLogHandshakeResponse response,
PlatformLogicalVersion targetLogicalVersion,
Object customBacklogMetadata) |
IHandshakeContext |
AbstractMultiBucketSingleFileGroupBacklog.processHandshakeResponse(String memberName,
IBacklogHandshakeRequest request,
IProcessLogHandshakeResponse response,
PlatformLogicalVersion targetLogicalVersion,
Object customBacklogMetadata) |
Modifier and Type | Class and Description |
---|---|
class |
MultiSourceSingleFileBacklogHandshakeRequest |
class |
MultiSourceSingleFileReliableAsyncBacklogHandshakeRequest |
Modifier and Type | Method and Description |
---|---|
protected IHandshakeContext |
AbstractMultiSourceSingleFileGroupBacklog.getHandshakeContext(String memberName,
IBacklogHandshakeRequest request,
PlatformLogicalVersion targetLogicalVersion,
GlobalOrderProcessLogHandshakeResponse typedResponse,
long lastProcessedKey) |
protected IHandshakeContext |
MultiSourceSingleFileReliableAsyncGroupBacklog.getHandshakeContext(String memberName,
IBacklogHandshakeRequest request,
PlatformLogicalVersion targetLogicalVersion,
GlobalOrderProcessLogHandshakeResponse typedResponse,
long lastProcessedKey) |
IHandshakeContext |
AbstractMultiSourceSingleFileGroupBacklog.processHandshakeResponse(String memberName,
IBacklogHandshakeRequest request,
IProcessLogHandshakeResponse response,
PlatformLogicalVersion targetLogicalVersion,
Object customBacklogMetadata) |
Modifier and Type | Method and Description |
---|---|
protected abstract AbstractReplicationTargetChannel |
AbstractReplicationTargetGroup.createNewChannelImpl(ReplicationEndpointDetails sourceEndpointDetails,
IReplicationMonitoredConnection sourceConnection,
IBacklogHandshakeRequest handshakeRequest,
IReplicationGroupHistory groupHistory) |
IProcessLogHandshakeResponse |
AbstractReplicationTargetChannel.performHandshake(IBacklogHandshakeRequest handshakeRequest) |
Modifier and Type | Method and Description |
---|---|
IBacklogHandshakeRequest |
ConnectChannelHandshakeRequest.getBacklogHandshakeRequest() |
Constructor and Description |
---|
ConnectChannelHandshakeRequest(IBacklogHandshakeRequest backlogHandshakeRequest) |
Modifier and Type | Method and Description |
---|---|
protected AbstractReplicationTargetChannel |
ReliableAsyncSingleOriginReplicationTargetGroup.createNewChannelImpl(ReplicationEndpointDetails sourceEndpointDetails,
IReplicationMonitoredConnection sourceConnection,
IBacklogHandshakeRequest handshakeRequest,
IReplicationGroupHistory groupHistory) |
Modifier and Type | Method and Description |
---|---|
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 |
---|---|
IReplicationReliableAsyncTargetProcessLog |
IReplicationReliableAsyncProcessLogBuilder.createReliableAsyncProcessLog(TargetGroupConfig groupConfig,
IBacklogHandshakeRequest handshakeRequest,
IReplicationInFacade replicationInFacade,
IReplicationProcessLogExceptionHandler exceptionHandler,
String myLookupName,
String groupName,
String sourceLookupName,
IReplicationReliableAsyncTargetProcessLog synchronizingProcessLog,
IReplicationGroupHistory groupHistory,
org.slf4j.Logger specificLogger) |
Copyright © GigaSpaces.