public interface IReplicationSourceGroup
IReplicationSourceChannel
. Each target member is receiving and processing the replication by a
corresponding IReplicationTargetGroup
.Modifier and Type | Method and Description |
---|---|
void |
beforeExecute(ReplicationOutContext replicationContext,
IEntryHolder entryHolder,
ReplicationSingleOperationType operationType)
Creates a single entry holder operation replication data from the given properties and add it
to the provided context
|
void |
beforeExecuteGeneric(ReplicationOutContext replicationContext,
Object operationData,
ReplicationSingleOperationType operationType)
Create a single type descriptor operation replication data and add it to provided context
|
void |
beforeTransactionExecute(ReplicationOutContext replicationContext,
ServerTransaction transaction,
ArrayList<IEntryHolder> lockedEntries,
ReplicationMultipleOperationType operationType)
Creates transaction replication data and adds it to the provided context
|
void |
beginSynchronizing(String synchronizingMemberLookupName,
Object synchronizingSourceUniqueId)
Signal this source group that one of its channel is now used for space synchronization
replica
|
void |
beginSynchronizing(String synchronizingMemberLookupName,
Object synchronizingSourceUniqueId,
boolean isDirectPersistencySync) |
boolean |
checkChannelConnected(String sourceMemberLookupName) |
void |
close()
Close this replication group, once closed it can no longer be used
|
void |
closeTemporaryChannel(String sourceMemberName)
Closes a temporary created channel
|
void |
createTemporaryChannel(String memberName,
Object customBacklogMetadata)
Creates a temporary channel to an existing member of this group, if a channel is already
created then this method does nothing This method should be called when there is a need to
create a temporary channel from this group to the target group to perform some operation and
should not be used for a persistent channel
|
String |
dumpState() |
int |
execute(IReplicationGroupOutContext groupContext)
Executes the replication specified by the provided group context
|
void |
execute(IReplicationUnreliableOperation operation) |
boolean |
flushPendingReplication(long timeout,
TimeUnit units) |
ReplicationEndpointDetails |
getChannelEndpointDetails(String sourceMemberLookupName) |
Map<String,Boolean> |
getChannelsStatus() |
DynamicSourceGroupConfigHolder |
getConfigHolder() |
IReplicationGroupBacklog |
getGroupBacklog() |
String |
getGroupName() |
IReplicationSourceGroupStatistics |
getStatistics() |
void |
monitorConsistencyLevel()
Monitors sla state of the replication group
|
void |
registerWith(MetricRegistrator metricRegister) |
void |
sampleStatistics() |
void |
setActive() |
void |
setPassive() |
void |
stopSynchronization(String synchronizingMemberLookupName)
Signal this source group that one of its channel synchronization state is aborted
beginSynchronizing(String, Object) |
void |
synchronizationCopyStageDone(String synchronizingMemberLookupName)
During synchronization process, notify the channel specified by the target name that the copy
iteration process is done in order for the filtering mechanism to know that any following
packets occurred completely after the synchronization copy stage.
|
boolean |
synchronizationDataGenerated(String synchronizingMemberLookupName,
String uid)
During synchronization process, notify the channel specified by the target name, that a sync
data was generated in order for it to know to filter older data when replicating to target
|
void beforeExecute(ReplicationOutContext replicationContext, IEntryHolder entryHolder, ReplicationSingleOperationType operationType)
replicationContext
- context to attach the replication data toentryHolder
- the entry holder dataoperationType
- the operation typevoid beforeExecuteGeneric(ReplicationOutContext replicationContext, Object operationData, ReplicationSingleOperationType operationType)
void beforeTransactionExecute(ReplicationOutContext replicationContext, ServerTransaction transaction, ArrayList<IEntryHolder> lockedEntries, ReplicationMultipleOperationType operationType)
int execute(IReplicationGroupOutContext groupContext)
void execute(IReplicationUnreliableOperation operation)
void close()
boolean checkChannelConnected(String sourceMemberLookupName)
ReplicationEndpointDetails getChannelEndpointDetails(String sourceMemberLookupName)
void beginSynchronizing(String synchronizingMemberLookupName, Object synchronizingSourceUniqueId)
synchronizingMemberLookupName
- the channel target name that is used for
synchronizationvoid beginSynchronizing(String synchronizingMemberLookupName, Object synchronizingSourceUniqueId, boolean isDirectPersistencySync)
boolean synchronizationDataGenerated(String synchronizingMemberLookupName, String uid)
void synchronizationCopyStageDone(String synchronizingMemberLookupName)
void stopSynchronization(String synchronizingMemberLookupName)
beginSynchronizing(String, Object)
String getGroupName()
IReplicationGroupBacklog getGroupBacklog()
void monitorConsistencyLevel() throws ConsistencyLevelViolationException
ConsistencyLevelViolationException
- if the sla is breachedIReplicationSourceGroupStatistics getStatistics()
void setActive()
void setPassive()
boolean flushPendingReplication(long timeout, TimeUnit units)
void sampleStatistics()
String dumpState()
DynamicSourceGroupConfigHolder getConfigHolder()
void createTemporaryChannel(String memberName, Object customBacklogMetadata)
memberName
- group member to create the channel tovoid closeTemporaryChannel(String sourceMemberName)
createTemporaryChannel(String, Object)
void registerWith(MetricRegistrator metricRegister)
Copyright © GigaSpaces.