| Modifier and Type | Method and Description |
|---|---|
IReplicationMonitoredConnection |
UnifiedReplicationRouter.getDirectConnection(RouterStubHolder remoteStubHolder) |
IReplicationMonitoredConnection |
UnifiedReplicationRouter.getMemberConnection(String memberLookupName) |
IReplicationMonitoredConnection |
UnifiedReplicationRouter.getMemberConnectionAsync(String memberLookupName) |
IReplicationMonitoredConnection |
UnifiedReplicationRouter.getUrlConnection(Object customUrl) |
IReplicationMonitoredConnection |
LusReplicationRouter.getUrlConnection(Object customUrl) |
| Modifier and Type | Method and Description |
|---|---|
IReplicationMonitoredConnection |
LocalClusterReplicationSinkRouter.getUrlConnection(Object customUrl) |
| Modifier and Type | Method and Description |
|---|---|
IReplicationMonitoredConnection |
AbstractReplicationSourceChannel.getConnection() |
| Modifier and Type | Method and Description |
|---|---|
protected abstract AbstractReplicationSourceChannel |
AbstractReplicationSourceGroup.createChannel(String memberLookupName,
IReplicationRouter replicationRouter,
IReplicationMonitoredConnection connection,
IReplicationChannelDataFilter dataFilter,
IReplicationGroupHistory groupHistory,
boolean dynamicMember,
SourceGroupConfig groupConfig,
Object customBacklogMetadata,
boolean resetTarget) |
protected abstract AbstractReplicationTargetChannel |
AbstractReplicationTargetGroup.createNewChannelImpl(ReplicationEndpointDetails sourceEndpointDetails,
IReplicationMonitoredConnection sourceConnection,
IBacklogHandshakeRequest handshakeRequest,
IReplicationGroupHistory groupHistory) |
| Modifier and Type | Method and Description |
|---|---|
protected AbstractReplicationSourceChannel |
ReliableAsyncReplicationSourceGroup.createChannel(String memberLookupName,
IReplicationRouter replicationRouter,
IReplicationMonitoredConnection connection,
IReplicationChannelDataFilter dataFilter,
IReplicationGroupHistory groupHistory,
boolean dynamicMember,
SourceGroupConfig groupConfig,
Object customBacklogMetadata,
boolean resetTarget) |
protected AbstractReplicationTargetChannel |
ReliableAsyncSingleOriginReplicationTargetGroup.createNewChannelImpl(ReplicationEndpointDetails sourceEndpointDetails,
IReplicationMonitoredConnection sourceConnection,
IBacklogHandshakeRequest handshakeRequest,
IReplicationGroupHistory groupHistory) |
| Constructor and Description |
|---|
ReliableAsyncReplicationSourceChannel(DynamicSourceGroupConfigHolder groupConfig,
String groupName,
String memberName,
IReplicationRouter replicationRouter,
IReplicationMonitoredConnection connection,
IReplicationReliableAsyncGroupBacklog groupBacklog,
IReplicationOutFilter outFilter,
int batchSize,
long intervalMilis,
int intervalOperations,
IAsyncHandlerProvider asyncHandlerProvider,
Collection<SyncReplicationSourceChannel> keeperSyncChannelsCollection,
IReplicationChannelDataFilter dataFilter,
IReplicationSourceGroupStateListener stateListener,
IReplicationGroupHistory groupHistory,
ReplicationStatistics.ReplicationMode channelType,
Object customBacklogMetadata,
String tag,
boolean resetTarget) |
| Constructor and Description |
|---|
SpaceCopyReplicaRunnable(ReplicationNode replicationNode,
IReplicationMonitoredConnection originConnection,
ISpaceReplicaDataConsumer replicaDataProcessor,
ISpaceCopyReplicaInFilter inFilter,
Object replicaRemoteContext,
int fetchBatchSize,
SpaceReplicaState state,
CyclicAtomicInteger orderProvider) |
SpaceReplicaState(IReplicationMonitoredConnection originConnection,
boolean isSynchronize,
long progressTimeout,
IReplicationTargetGroup targetGroup) |
| Modifier and Type | Method and Description |
|---|---|
protected IReplicationMonitoredConnection |
AbstractConnectionProxyBasedReplicationRouter.createDirectConnection(String lookupName,
boolean connectSynchronously) |
IReplicationMonitoredConnection |
IReplicationRouter.getDirectConnection(RouterStubHolder remoteStubHolder)
Gets a direct connection to the router represented by the given stub.
|
IReplicationMonitoredConnection |
AbstractConnectionProxyBasedReplicationRouter.getDirectConnection(RouterStubHolder remoteStubHolder) |
IReplicationMonitoredConnection |
IReplicationRouter.getMemberConnection(String memberLookupName)
Create new replication connection and establishes it.
|
IReplicationMonitoredConnection |
AbstractConnectionProxyBasedReplicationRouter.getMemberConnection(String lookupName) |
IReplicationMonitoredConnection |
IReplicationRouter.getMemberConnectionAsync(String memberLookupName)
Gets a replication connection to a designated replication node by its name, the received
connection is automatically managed by the router and it is in charge of detecting
disconnection and reestablish connection when available.
|
IReplicationMonitoredConnection |
AbstractConnectionProxyBasedReplicationRouter.getMemberConnectionAsync(String lookupName) |
IReplicationMonitoredConnection |
IReplicationRouter.getUrlConnection(Object customUrl)
Gets a connection with given custom url, need to have this due to space copy with given url
which may not even reside in the cluster policy and for sink recovery
|
IReplicationMonitoredConnection |
DirectOnlyReplicationRouter.getUrlConnection(Object customUrl) |
| Modifier and Type | Class and Description |
|---|---|
class |
ConnectionReference<T,L> |
| Modifier and Type | Method and Description |
|---|---|
IReplicationMonitoredConnection |
SpaceProxyReplicationRouter.getUrlConnection(Object customUrl) |
Copyright © GigaSpaces.