Modifier and Type | Method and Description |
---|---|
protected <T extends SourceGroupConfig> |
AbstractSingleFileGroupBacklog.getGroupConfigSnapshot() |
Modifier and Type | Method and Description |
---|---|
protected abstract Map<String,CType> |
AbstractSingleFileGroupBacklog.createConfirmationMap(SourceGroupConfig groupConfig) |
void |
AbstractSingleFileGroupBacklog.memberAdded(MemberAddedEvent memberAddedParam,
SourceGroupConfig newConfig) |
void |
AbstractSingleFileGroupBacklog.memberRemoved(String memberName,
SourceGroupConfig newConfig) |
protected void |
AbstractSingleFileGroupBacklog.updateBacklogLimitations(SourceGroupConfig groupConfig) |
Modifier and Type | Method and Description |
---|---|
protected Map<String,GlobalOrderConfirmationHolder> |
AbstractGlobalOrderGroupBacklog.createConfirmationMap(SourceGroupConfig groupConfig) |
Modifier and Type | Method and Description |
---|---|
protected Map<String,MultiBucketSingleFileConfirmationHolder> |
AbstractMultiBucketSingleFileGroupBacklog.createConfirmationMap(SourceGroupConfig groupConfig) |
Modifier and Type | Method and Description |
---|---|
protected Map<String,MultiSourceSingleFileConfirmationHolder> |
AbstractMultiSourceSingleFileGroupBacklog.createConfirmationMap(SourceGroupConfig groupConfig) |
Constructor and Description |
---|
DynamicSourceGroupConfigHolder(SourceGroupConfig config) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractReplicationSourceGroup<T extends SourceGroupConfig> |
class |
AbstractReplicationSourceGroupBuilder<T extends SourceGroupConfig> |
Modifier and Type | Method and Description |
---|---|
protected SourceGroupConfig |
AbstractReplicationSourceGroupBuilder.getGroupConfig() |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractReplicationSourceGroup.createChannel(String memberLookupName,
boolean dynamicMember,
SourceGroupConfig config,
boolean connectSynchronously,
Object customBacklogMetadata,
boolean resetTarget) |
protected abstract AbstractReplicationSourceChannel |
AbstractReplicationSourceGroup.createChannel(String memberLookupName,
IReplicationRouter replicationRouter,
IReplicationMonitoredConnection connection,
IReplicationChannelDataFilter dataFilter,
IReplicationGroupHistory groupHistory,
boolean dynamicMember,
SourceGroupConfig groupConfig,
Object customBacklogMetadata,
boolean resetTarget) |
protected String[] |
AbstractReplicationSourceGroup.getPotentialRemovedMembers(SourceGroupConfig config) |
void |
ReliableAsyncKeeperLruCentralDataSourceReplicationChannelDataFilter.memberAdded(MemberAddedEvent memberAddedParam,
SourceGroupConfig newConfig) |
void |
AbstractReplicationSourceGroup.memberAdded(MemberAddedEvent memberAddedEvent,
SourceGroupConfig newConfig) |
void |
ReliableAsyncKeeperLruCentralDataSourceReplicationChannelDataFilter.memberRemoved(String memberName,
SourceGroupConfig newConfig) |
void |
AbstractReplicationSourceGroup.memberRemoved(String memberName,
SourceGroupConfig newConfig) |
protected void |
AbstractReplicationSourceGroup.onMemberAdded(MemberAddedEvent memberAddedEvent,
SourceGroupConfig newConfig) |
protected void |
AbstractReplicationSourceGroup.onMemberRemoved(String memberName,
SourceGroupConfig newConfig) |
Modifier and Type | Class and Description |
---|---|
class |
AsyncSourceGroupConfig |
Modifier and Type | Method and Description |
---|---|
protected AbstractReplicationSourceChannel |
AsyncReplicationSourceGroup.createChannel(String memberLookupName,
IReplicationRouter replicationRouter,
IReplicationMonitoredConnection connection,
IReplicationChannelDataFilter dataFilter,
IReplicationGroupHistory groupHistory,
boolean dynamicMember,
SourceGroupConfig groupConfig,
Object customBacklogMetadata,
boolean resetTarget) |
protected String[] |
AsyncReplicationSourceGroup.getPotentialRemovedMembers(SourceGroupConfig config) |
Modifier and Type | Class and Description |
---|---|
class |
ReliableAsyncSourceGroupConfig |
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 String[] |
ReliableAsyncReplicationSourceGroup.getPotentialRemovedMembers(SourceGroupConfig config) |
protected void |
ReliableAsyncReplicationSourceGroup.notifyKeepersOfGroupMembersChange(SourceGroupConfig newConfig) |
protected void |
ReliableAsyncReplicationSourceGroup.onMemberAdded(MemberAddedEvent memberAddedEvent,
SourceGroupConfig newConfig) |
protected void |
ReliableAsyncReplicationSourceGroup.onMemberRemoved(String memberName,
SourceGroupConfig newConfig) |
Modifier and Type | Method and Description |
---|---|
protected AbstractReplicationSourceChannel |
SyncReplicationSourceGroup.createChannel(String memberLookupName,
IReplicationRouter replicationRouter,
IReplicationMonitoredConnection connection,
IReplicationChannelDataFilter dataFilter,
IReplicationGroupHistory groupHistory,
boolean dynamicMember,
SourceGroupConfig groupConfig,
Object customBacklogMetadata,
boolean resetTarget) |
Copyright © GigaSpaces.