Package com.gigaspaces.internal.cluster.node.impl

Class ReplicationNode

java.lang.Object

com.gigaspaces.internal.cluster.node.impl.ReplicationNode

All Implemented Interfaces:

IReplicationSourceGroupStateListener, IReplicationTargetGroupStateListener, IIncomingReplicationFacade, IReplicationNodePluginFacade, IReplicaRequestFacade, IIncomingReplicationHandler, IReplicationNode

public class ReplicationNode
extends Object
implements IReplicationNode, IIncomingReplicationHandler, IIncomingReplicationFacade, IReplicationTargetGroupStateListener, IReplicationSourceGroupStateListener

The implementation of the IReplicationNode interface

Since:

8.0

Author:

eitany

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	ReplicationNode.StatisticsMonitor

Constructor Summary

Constructors

Constructor	Description
ReplicationNode(ReplicationNodeConfig replicationNodeConfig, IReplicationNodeBuilder nodeBuilder, String name, MetricRegistrator metricRegister)

Method Summary

Modifier and Type	Method	Description
<T> T	accept(AbstractReplicationPacket<T> packet)
void	clearStaleReplicas(long expirationTime)
void	close()	Closes the node, once closed the node is no longer usable.
IReplicationOutContext	createContext()
String	dumpState()
int	execute(IReplicationOutContext context)	Executes the accumulated replication according to the given context
boolean	flushPendingReplication(long timeout, TimeUnit units)
int	flushRedoLogToStorage()
IReplicationNodeAdmin	getAdmin()
IRedoLogStatistics	getBackLogStatistics()
BlobStoreReplicaConsumeHelper	getBlobStoreReplicaConsumeHelper()
BlobStoreReplicationBulkConsumeHelper	getBlobStoreReplicationBulkConsumeHelper()
DirectPersistencyBackupSyncIteratorHandler	getDirectPersistencyBackupSyncIteratorHandler()
IDirectPersistencySyncHandler	getDirectPesistencySyncHandler()
ReplicationEndpointDetails	getEndpointDetails()
IReplicationGroupBacklog	getGroupBacklogByRequestContext(Object requestContext)
String	getLogPrefix()
MetricRegistrator	getMetricRegister()
String	getName()
Collection<ISpaceReplicaData>	getNextReplicaBatch(Object context, int fetchBatchSize)
RouterStubHolder	getRemoteRouterStub(String routerLookupName)
ReplicationNodeReplicaHandler	getReplicaHandler()
IReplicationRouter	getReplicationRouter()
ReplicationRouterBuilder	getReplicationRouterBuilder()
IReplicationSourceGroup	getReplicationSourceGroup(String groupName)
IReplicationTargetGroup	getReplicationTargetGroup(String groupName)
IReplicationRouterAdmin	getRouterAdmin()
Object	getUniqueId()
void	monitorState(OperationWeightInfo info)
Object	newReplicaRequest(String requesterLookupName, ReplicaRequestPacket replicaRequestPacket)
CurrentStageInfo	nextReplicaStage(Object replicaRemoteContext)
void	onNewReplicaRequest(String groupName, String channelName, boolean isSynchronizeRequest)
<T> T	onReplication(AbstractReplicationPacket<T> packet)	Handles incoming replication packet
void	onSourceBrokenReplicationTopology(String groupName, String channelMemberName, BrokenReplicationTopologyException error)
void	onSourceChannelActivated(String groupName, String memberName)
void	onTargetChannelBacklogDropped(String groupName, String channelSourceLooString, IBacklogMemberState memberState)	Called when a target channel received a notice that its backlog was dropped at the source
void	onTargetChannelConnected(String groupName, String sourceMemberName, Object sourceUniqueId)	Called when a target channel is connected/created
void	onTargetChannelCreationValidation(String groupName, String sourceMemberName, Object sourceUniqueId)	Called when a new channel is being established, just before the channel is created to allow custom validation logic.
boolean	onTargetChannelOutOfSync(String groupName, String channelSourceLookupName, IncomingReplicationOutOfSyncException outOfSyncReason)	Called when a target channel failed handshake due to becoming out of sync
void	onTargetChannelSourceDisconnected(String groupName, String sourceMemberName, Object sourceUniqueId)	Called when a target channel lost connection to its source
void	outCancelEntryLease(IReplicationOutContext context, IEntryHolder entryHolder)	Notify replication node that an entry lease was canceled
void	outChangeEntry(IReplicationOutContext context, IEntryHolder entryHolder)	Notify replication node that an entry was changed
void	outDataTypeAddIndex(IReplicationOutContext context, AddTypeIndexesRequestInfo addIndexesRequest)	Notify the replication node that new index was added to this data type
void	outDataTypeDrop(IReplicationOutContext context, String className)
void	outDataTypeIntroduce(IReplicationOutContext context, ITypeDesc typeDescriptor)	Notify the replication node that new data type was introduced
void	outEntryLeaseExpired(IReplicationOutContext context, IEntryHolder entryHolder)	Notify replication node that an entry lease expired
void	outEvictEntry(IReplicationOutContext context, IEntryHolder entryHolder)	Notify replication node that an entry was evicted
void	outExtendEntryLeasePeriod(IReplicationOutContext context, IEntryHolder entryHolder)	Notify replication node that an entry lease is extended
void	outExtendNotifyTemplateLeasePeriod(IReplicationOutContext context, NotifyTemplateHolder entryHolder)	Notify replication node that a notify template lease is extended
void	outInsertNotifyTemplate(IReplicationOutContext context, NotifyTemplateHolder templateHolder)	Notify replication node that a new notify template was inserted
void	outNotificationSentAndExecute(OperationID operationId)	Notify and dispatch the replication event representing that a notification was sent successfully
void	outNotifyTemplateLeaseExpired(IReplicationOutContext context, NotifyTemplateHolder templateHolder)	Notify replication node that an notify template lease expired
void	outRemoveEntry(IReplicationOutContext context, IEntryHolder entryHolder)	Notify replication node that an entry was removed
void	outRemoveNotifyTemplate(IReplicationOutContext context, NotifyTemplateHolder templateHolder)	Notify replication node that a notify template was removed
void	outTransaction(IReplicationOutContext context, ServerTransaction transaction, ArrayList<IEntryHolder> lockedEntries)	Notify replication node that a transaction is executed in one stage (one phase commit)
void	outTransactionAbort(IReplicationOutContext context, ServerTransaction transaction)	Notify replication node that a transaction abort is executed (two phase commit)
void	outTransactionCommit(IReplicationOutContext context, ServerTransaction transaction)	Notify replication node that a transaction commit is executed (two phase commit)
void	outTransactionPrepare(IReplicationOutContext context, ServerTransaction transaction, ArrayList<IEntryHolder> lockedEntries)	Notify replication node that a transaction prepare is executed (two phase commit)
void	outUpdateEntry(IReplicationOutContext context, IEntryHolder entryHolder)	Notify replication node that an entry was updated
void	outWriteEntry(IReplicationOutContext context, IEntryHolder entryHolder)	Notify replication node that a new entry was written
void	reregisterMetrics()	Re-registers all replication metrics after a space mode change.
void	rollbackCopyReplica(ISpaceCopyResult replicaResult)
void	setBlobStoreReplicaConsumeHelper(BlobStoreReplicaConsumeHelper blobStoreReplicaConsumeHelper)
void	setBlobStoreReplicationBulkConsumeHelper(BlobStoreReplicationBulkConsumeHelper blobStoreReplicationBulkConsumeHelper)
void	setDirectPersistencyBackupSyncIteratorHandler(DirectPersistencyBackupSyncIteratorHandler directPersistencyBackupSyncIteratorHandler)
void	setInBatchConsumptionHandler(IReplicationInBatchConsumptionHandler handler)	Sets a handler for incoming replication upon batch consumption completion
void	setInDataTypeCreatedHandler(IReplicationInDataTypeCreatedHandler handler)	Sets a handler for incoming data type replication event which was generated by a different node as a result of IReplicationNode.outDataTypeIntroduce(IReplicationOutContext, ITypeDesc)
void	setInDataTypeDrop(SpaceReplicationMetadataEventHandler handler)
void	setInDataTypeIndexAddedHandler(IReplicationInDataTypeIndexAddedHandler handler)	Sets a handler for incoming data type add index replication event which was generated by a different node as a result of IReplicationNode.outDataTypeIntroduce(IReplicationOutContext, ITypeDesc)
void	setInEntryHandler(IReplicationInEntryHandler handler)	Sets a handler for incoming write entry replication event which was generated by a different node as a result of IReplicationNode.outWriteEntry(IReplicationOutContext, IEntryHolder)
void	setInEntryLeaseCancelledHandler(IReplicationInEntryLeaseCancelledHandler handler)	Sets a handler for incoming cancel entry lease replication event which was generated by a different node as a result of IReplicationNode.outCancelEntryLease(IReplicationOutContext, IEntryHolder)
void	setInEntryLeaseExpiredHandler(IReplicationInEntryLeaseExpiredHandler handler)	Sets a handler for incoming entry lease expired replication event which was generated by a different node as a result of IReplicationNode.outCancelEntryLease(IReplicationOutContext, IEntryHolder)
void	setInEntryLeaseExtendedHandler(IReplicationInEntryLeaseExtendedHandler handler)	Sets a handler for incoming extend lease replication event which was generated by a different node as a result of IReplicationNode.outExtendEntryLeasePeriod(IReplicationOutContext, IEntryHolder)
void	setInEvictEntryHandler(IReplicationInEvictEntryHandler handler)	Sets a handler for incoming evict entry replication event which was generated by a different node as a result of IReplicationNode.outEvictEntry(IReplicationOutContext, IEntryHolder)
void	setInNotificationSentHandler(IReplicationInNotificationSentHandler handler)	Sets a handler for incoming notification sent event which was generated by a different node as a result of IReplicationNode.outNotificationSentAndExecute(OperationID)
void	setInNotifyTemplateCreatedHandler(IReplicationInNotifyTemplateCreatedHandler handler)	Sets a handler for incoming insert notify template replication event which was generated by a different node as a result of IReplicationNode.outInsertNotifyTemplate(IReplicationOutContext, NotifyTemplateHolder)
void	setInNotifyTemplateLeaseExpiredHandler(IReplicationInNotifyTemplateLeaseExpiredHandler handler)	Sets a handler for incoming notify-template lease expired replication event which was generated by a different node as a result of IReplicationNode.outNotifyTemplateLeaseExpired(IReplicationOutContext, NotifyTemplateHolder)
void	setInNotifyTemplateLeaseExtendedHandler(IReplicationInNotifyTemplateLeaseExtendedHandler handler)	Sets a handler for incoming extend lease replication event which was generated by a different node as a result of #outExtendNotifyTemplateLeasePeriod(IReplicationOutContext, IEntryHolder)
void	setInNotifyTemplateRemovedHandler(IReplicationInNotifyTemplateRemovedHandler handler)	Sets a handler for incoming remove notify template replication event which was generated by a different node as a result of IReplicationNode.outRemoveNotifyTemplate(IReplicationOutContext, NotifyTemplateHolder)
void	setInTransactionHandler(IReplicationInTransactionHandler handler)	Sets a handler for incoming transaction replication event which was generated by a different node as a result of #outTransaction(IReplicationOutContext, ServerTransaction, ArrayList<EntryCacheInfo>)
void	setNodeStateListener(IReplicationNodeStateListener listener)
void	setTag(String tag)
ISpaceCopyReplicaState	spaceCopyReplicaRequest(ISpaceCopyReplicaRequestContext context)	Starts a space copy replica request, will copy the current state of a remote space.
ISpaceSynchronizeReplicaState	spaceSynchronizeReplicaRequest(ISpaceSynchronizeReplicaRequestContext context)	Starts a space synchronize replica request, will copy the current state of a remote space and synchronize with ongoing changes, the synchronization can only occurr if the target space has replication channel to this space (Recovery).
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details

ReplicationNode

public ReplicationNode(ReplicationNodeConfig replicationNodeConfig,
 IReplicationNodeBuilder nodeBuilder,
 String name,
 MetricRegistrator metricRegister)

Method Details

getName

public String getName()

getUniqueId

public Object getUniqueId()

createContext

public IReplicationOutContext createContext()

Specified by:

createContext in interface IReplicationNode

Returns:

create a replication out context

execute

public int execute(IReplicationOutContext context)

Description copied from interface: IReplicationNode

Executes the accumulated replication according to the given context

Specified by:

execute in interface IReplicationNode

Parameters:

context - replication context

Returns:

true number of completed replications.

getReplicationRouterBuilder

public ReplicationRouterBuilder getReplicationRouterBuilder()

getReplicationRouter

public IReplicationRouter getReplicationRouter()

getAdmin

public IReplicationNodeAdmin getAdmin()

Specified by:

getAdmin in interface IReplicationNode

Returns:

administrator of the replication node

outCancelEntryLease

public void outCancelEntryLease(IReplicationOutContext context,
 IEntryHolder entryHolder)

Description copied from interface: IReplicationNode

Notify replication node that an entry lease was canceled

Specified by:

outCancelEntryLease in interface IReplicationNode

Parameters:

context - the context of the operation

entryHolder - entry of which its lease was canceled

outEntryLeaseExpired

public void outEntryLeaseExpired(IReplicationOutContext context,
 IEntryHolder entryHolder)

Description copied from interface: IReplicationNode

Notify replication node that an entry lease expired

Specified by:

outEntryLeaseExpired in interface IReplicationNode

Parameters:

context - the context of the operation

entryHolder - entry of which its lease expired

outNotifyTemplateLeaseExpired

public void outNotifyTemplateLeaseExpired(IReplicationOutContext context,
 NotifyTemplateHolder templateHolder)

Description copied from interface: IReplicationNode

Notify replication node that an notify template lease expired

Specified by:

outNotifyTemplateLeaseExpired in interface IReplicationNode

Parameters:

context - the context of the operation

templateHolder - of which its lease expired

outEvictEntry

public void outEvictEntry(IReplicationOutContext context,
 IEntryHolder entryHolder)

Description copied from interface: IReplicationNode

Notify replication node that an entry was evicted

Specified by:

outEvictEntry in interface IReplicationNode

Parameters:

context - the context of the operation

entryHolder - evicted entry

outExtendEntryLeasePeriod

public void outExtendEntryLeasePeriod(IReplicationOutContext context,
 IEntryHolder entryHolder)

Description copied from interface: IReplicationNode

Notify replication node that an entry lease is extended

Specified by:

outExtendEntryLeasePeriod in interface IReplicationNode

Parameters:

context - the context of the operation

outExtendNotifyTemplateLeasePeriod

public void outExtendNotifyTemplateLeasePeriod(IReplicationOutContext context,
 NotifyTemplateHolder entryHolder)

Description copied from interface: IReplicationNode

Notify replication node that a notify template lease is extended

Specified by:

outExtendNotifyTemplateLeasePeriod in interface IReplicationNode

Parameters:

context - the context of the operation

outInsertNotifyTemplate

public void outInsertNotifyTemplate(IReplicationOutContext context,
 NotifyTemplateHolder templateHolder)

Description copied from interface: IReplicationNode

Notify replication node that a new notify template was inserted

Specified by:

outInsertNotifyTemplate in interface IReplicationNode

Parameters:

context - the context of the operation

templateHolder - inserted template

outNotificationSentAndExecute

public void outNotificationSentAndExecute(OperationID operationId)

Description copied from interface: IReplicationNode

Notify and dispatch the replication event representing that a notification was sent successfully

Specified by:

outNotificationSentAndExecute in interface IReplicationNode

outRemoveEntry

public void outRemoveEntry(IReplicationOutContext context,
 IEntryHolder entryHolder)

Description copied from interface: IReplicationNode

Notify replication node that an entry was removed

Specified by:

outRemoveEntry in interface IReplicationNode

Parameters:

context - the context of the operation

entryHolder - removed entry

outRemoveNotifyTemplate

public void outRemoveNotifyTemplate(IReplicationOutContext context,
 NotifyTemplateHolder templateHolder)

Description copied from interface: IReplicationNode

Notify replication node that a notify template was removed

Specified by:

outRemoveNotifyTemplate in interface IReplicationNode

Parameters:

context - the context of the operation

templateHolder - removed template

outTransaction

public void outTransaction(IReplicationOutContext context,
 ServerTransaction transaction,
 ArrayList<IEntryHolder> lockedEntries)

Description copied from interface: IReplicationNode

Notify replication node that a transaction is executed in one stage (one phase commit)

Specified by:

outTransaction in interface IReplicationNode

transaction - executed transaction

lockedEntries - entries participating in the transaction and their corresponding operation

outTransactionCommit

public void outTransactionCommit(IReplicationOutContext context,
 ServerTransaction transaction)

Description copied from interface: IReplicationNode

Notify replication node that a transaction commit is executed (two phase commit)

Specified by:

outTransactionCommit in interface IReplicationNode

transaction - committed transaction

outTransactionAbort

public void outTransactionAbort(IReplicationOutContext context,
 ServerTransaction transaction)

Description copied from interface: IReplicationNode

Notify replication node that a transaction abort is executed (two phase commit)

Specified by:

outTransactionAbort in interface IReplicationNode

transaction - committed transaction

outTransactionPrepare

public void outTransactionPrepare(IReplicationOutContext context,
 ServerTransaction transaction,
 ArrayList<IEntryHolder> lockedEntries)

Description copied from interface: IReplicationNode

Notify replication node that a transaction prepare is executed (two phase commit)

Specified by:

outTransactionPrepare in interface IReplicationNode

transaction - prepared transaction

lockedEntries - entries participating in the transaction and their corresponding operation

outUpdateEntry

public void outUpdateEntry(IReplicationOutContext context,
 IEntryHolder entryHolder)

Description copied from interface: IReplicationNode

Notify replication node that an entry was updated

Specified by:

outUpdateEntry in interface IReplicationNode

Parameters:

context - the context of the operation

entryHolder - updated entry

outChangeEntry

public void outChangeEntry(IReplicationOutContext context,
 IEntryHolder entryHolder)

Description copied from interface: IReplicationNode

Notify replication node that an entry was changed

Specified by:

outChangeEntry in interface IReplicationNode

Parameters:

context - the context of the operation

entryHolder - mutated entry

outWriteEntry

public void outWriteEntry(IReplicationOutContext context,
 IEntryHolder entryHolder)

Description copied from interface: IReplicationNode

Notify replication node that a new entry was written

Specified by:

outWriteEntry in interface IReplicationNode

Parameters:

context - the context of the operation

entryHolder - written entry

outDataTypeIntroduce

public void outDataTypeIntroduce(IReplicationOutContext context,
 ITypeDesc typeDescriptor)

Description copied from interface: IReplicationNode

Notify the replication node that new data type was introduced

Specified by:

outDataTypeIntroduce in interface IReplicationNode

typeDescriptor - the updated type descriptor

outDataTypeDrop

public void outDataTypeDrop(IReplicationOutContext context,
 String className)

Specified by:

outDataTypeDrop in interface IReplicationNode

outDataTypeAddIndex

public void outDataTypeAddIndex(IReplicationOutContext context,
 AddTypeIndexesRequestInfo addIndexesRequest)

Description copied from interface: IReplicationNode

Notify the replication node that new index was added to this data type

Specified by:

outDataTypeAddIndex in interface IReplicationNode

setInEvictEntryHandler

public void setInEvictEntryHandler(IReplicationInEvictEntryHandler handler)

Description copied from interface: IReplicationNode

Sets a handler for incoming evict entry replication event which was generated by a different node as a result of IReplicationNode.outEvictEntry(IReplicationOutContext, IEntryHolder)

Specified by:

setInEvictEntryHandler in interface IReplicationNode

setInNotificationSentHandler

public void setInNotificationSentHandler(IReplicationInNotificationSentHandler handler)

Description copied from interface: IReplicationNode

Sets a handler for incoming notification sent event which was generated by a different node as a result of IReplicationNode.outNotificationSentAndExecute(OperationID)

Specified by:

setInNotificationSentHandler in interface IReplicationNode

setInTransactionHandler

public void setInTransactionHandler(IReplicationInTransactionHandler handler)

Description copied from interface: IReplicationNode

Sets a handler for incoming transaction replication event which was generated by a different node as a result of #outTransaction(IReplicationOutContext, ServerTransaction, ArrayList<EntryCacheInfo>)

Specified by:

setInTransactionHandler in interface IReplicationNode

setInEntryHandler

public void setInEntryHandler(IReplicationInEntryHandler handler)

Description copied from interface: IReplicationNode

Sets a handler for incoming write entry replication event which was generated by a different node as a result of IReplicationNode.outWriteEntry(IReplicationOutContext, IEntryHolder)

Specified by:

setInEntryHandler in interface IReplicationNode

setInEntryLeaseCancelledHandler

public void setInEntryLeaseCancelledHandler(IReplicationInEntryLeaseCancelledHandler handler)

Description copied from interface: IReplicationNode

Sets a handler for incoming cancel entry lease replication event which was generated by a different node as a result of IReplicationNode.outCancelEntryLease(IReplicationOutContext, IEntryHolder)

Specified by:

setInEntryLeaseCancelledHandler in interface IReplicationNode

setInEntryLeaseExtendedHandler

public void setInEntryLeaseExtendedHandler(IReplicationInEntryLeaseExtendedHandler handler)

Description copied from interface: IReplicationNode

Sets a handler for incoming extend lease replication event which was generated by a different node as a result of IReplicationNode.outExtendEntryLeasePeriod(IReplicationOutContext, IEntryHolder)

Specified by:

setInEntryLeaseExtendedHandler in interface IReplicationNode

setInEntryLeaseExpiredHandler

public void setInEntryLeaseExpiredHandler(IReplicationInEntryLeaseExpiredHandler handler)

Description copied from interface: IReplicationNode

Sets a handler for incoming entry lease expired replication event which was generated by a different node as a result of IReplicationNode.outCancelEntryLease(IReplicationOutContext, IEntryHolder)

Specified by:

setInEntryLeaseExpiredHandler in interface IReplicationNode

setInNotifyTemplateCreatedHandler

public void setInNotifyTemplateCreatedHandler(IReplicationInNotifyTemplateCreatedHandler handler)

Description copied from interface: IReplicationNode

Sets a handler for incoming insert notify template replication event which was generated by a different node as a result of IReplicationNode.outInsertNotifyTemplate(IReplicationOutContext, NotifyTemplateHolder)

Specified by:

setInNotifyTemplateCreatedHandler in interface IReplicationNode

setInNotifyTemplateRemovedHandler

public void setInNotifyTemplateRemovedHandler(IReplicationInNotifyTemplateRemovedHandler handler)

Description copied from interface: IReplicationNode

Sets a handler for incoming remove notify template replication event which was generated by a different node as a result of IReplicationNode.outRemoveNotifyTemplate(IReplicationOutContext, NotifyTemplateHolder)

Specified by:

setInNotifyTemplateRemovedHandler in interface IReplicationNode

setInNotifyTemplateLeaseExtendedHandler

public void setInNotifyTemplateLeaseExtendedHandler(IReplicationInNotifyTemplateLeaseExtendedHandler handler)

Description copied from interface: IReplicationNode

Sets a handler for incoming extend lease replication event which was generated by a different node as a result of #outExtendNotifyTemplateLeasePeriod(IReplicationOutContext, IEntryHolder)

Specified by:

setInNotifyTemplateLeaseExtendedHandler in interface IReplicationNode

setInNotifyTemplateLeaseExpiredHandler

public void setInNotifyTemplateLeaseExpiredHandler(IReplicationInNotifyTemplateLeaseExpiredHandler handler)

Description copied from interface: IReplicationNode

Sets a handler for incoming notify-template lease expired replication event which was generated by a different node as a result of IReplicationNode.outNotifyTemplateLeaseExpired(IReplicationOutContext, NotifyTemplateHolder)

Specified by:

setInNotifyTemplateLeaseExpiredHandler in interface IReplicationNode

setInDataTypeCreatedHandler

public void setInDataTypeCreatedHandler(IReplicationInDataTypeCreatedHandler handler)

Description copied from interface: IReplicationNode

Sets a handler for incoming data type replication event which was generated by a different node as a result of IReplicationNode.outDataTypeIntroduce(IReplicationOutContext, ITypeDesc)

Specified by:

setInDataTypeCreatedHandler in interface IReplicationNode

setInDataTypeDrop

public void setInDataTypeDrop(SpaceReplicationMetadataEventHandler handler)

setInDataTypeIndexAddedHandler

public void setInDataTypeIndexAddedHandler(IReplicationInDataTypeIndexAddedHandler handler)

Description copied from interface: IReplicationNode

Sets a handler for incoming data type add index replication event which was generated by a different node as a result of IReplicationNode.outDataTypeIntroduce(IReplicationOutContext, ITypeDesc)

Specified by:

setInDataTypeIndexAddedHandler in interface IReplicationNode

setInBatchConsumptionHandler

public void setInBatchConsumptionHandler(IReplicationInBatchConsumptionHandler handler)

Description copied from interface: IReplicationNode

Sets a handler for incoming replication upon batch consumption completion

Specified by:

setInBatchConsumptionHandler in interface IReplicationNode

spaceSynchronizeReplicaRequest

public ISpaceSynchronizeReplicaState spaceSynchronizeReplicaRequest(ISpaceSynchronizeReplicaRequestContext context)

Description copied from interface: IReplicationNode

Starts a space synchronize replica request, will copy the current state of a remote space and synchronize with ongoing changes, the synchronization can only occurr if the target space has replication channel to this space (Recovery).

Specified by:

spaceSynchronizeReplicaRequest in interface IReplicationNode

Returns:

space synchronize replica state representing the current progress of the synchronization

spaceCopyReplicaRequest

public ISpaceCopyReplicaState spaceCopyReplicaRequest(ISpaceCopyReplicaRequestContext context)

Description copied from interface: IReplicationNode

Starts a space copy replica request, will copy the current state of a remote space. Should be used when the target space is in a static state, meaning its data state do not change during the copy, otherwise the copy result is not guaranteed to be an exact replica of the target space (Offline copy, for admin purposes).

Specified by:

spaceCopyReplicaRequest in interface IReplicationNode

Returns:

space copy replica state representing the current progress of the copy operation

rollbackCopyReplica

public void rollbackCopyReplica(ISpaceCopyResult replicaResult)

Specified by:

rollbackCopyReplica in interface IReplicationNode

close

public void close()

Description copied from interface: IReplicationNode

Closes the node, once closed the node is no longer usable.

Specified by:

close in interface IReplicationNode

setBlobStoreReplicationBulkConsumeHelper

public void setBlobStoreReplicationBulkConsumeHelper(BlobStoreReplicationBulkConsumeHelper blobStoreReplicationBulkConsumeHelper)

Specified by:

setBlobStoreReplicationBulkConsumeHelper in interface IReplicationNode

getBlobStoreReplicationBulkConsumeHelper

public BlobStoreReplicationBulkConsumeHelper getBlobStoreReplicationBulkConsumeHelper()

Specified by:

getBlobStoreReplicationBulkConsumeHelper in interface IReplicationNode

onReplication

public <T> T onReplication(AbstractReplicationPacket<T> packet)
                    throws RemoteException

Description copied from interface: IIncomingReplicationHandler

Handles incoming replication packet

Specified by:

onReplication in interface IIncomingReplicationHandler

Parameters:

packet - incoming packet

Returns:

incoming replication result

Throws:

RemoteException

reregisterMetrics

public void reregisterMetrics()

Re-registers all replication metrics after a space mode change. This is necessary because Micrometer tags are immutable - when a space changes from backup to primary (or vice versa), the metrics must be unregistered and re-registered with updated tag values (space_active, space_primary). Called from SpaceEngine.reregisterMetricsAfterModeChange() during failover.

getReplicationTargetGroup

public IReplicationTargetGroup getReplicationTargetGroup(String groupName)
                                                  throws NoSuchReplicationGroupExistException

Specified by:

getReplicationTargetGroup in interface IIncomingReplicationFacade

Throws:

NoSuchReplicationGroupExistException

getReplicationSourceGroup

public IReplicationSourceGroup getReplicationSourceGroup(String groupName)
                                                  throws NoSuchReplicationGroupExistException

Specified by:

getReplicationSourceGroup in interface IIncomingReplicationFacade

Throws:

NoSuchReplicationGroupExistException

getGroupBacklogByRequestContext

public IReplicationGroupBacklog getGroupBacklogByRequestContext(Object requestContext)

getRemoteRouterStub

public RouterStubHolder getRemoteRouterStub(String routerLookupName)

Specified by:

getRemoteRouterStub in interface IIncomingReplicationFacade

getEndpointDetails

public ReplicationEndpointDetails getEndpointDetails()

Specified by:

getEndpointDetails in interface IIncomingReplicationFacade

accept

public <T> T accept(AbstractReplicationPacket<T> packet)

Specified by:

accept in interface IReplicationNodePluginFacade

newReplicaRequest

public Object newReplicaRequest(String requesterLookupName,
 ReplicaRequestPacket replicaRequestPacket)

Specified by:

newReplicaRequest in interface IReplicaRequestFacade

getNextReplicaBatch

public Collection<ISpaceReplicaData> getNextReplicaBatch(Object context,
 int fetchBatchSize)

Specified by:

getNextReplicaBatch in interface IReplicaRequestFacade

clearStaleReplicas

public void clearStaleReplicas(long expirationTime)

nextReplicaStage

public CurrentStageInfo nextReplicaStage(Object replicaRemoteContext)

Specified by:

nextReplicaStage in interface IReplicaRequestFacade

getLogPrefix

public String getLogPrefix()

toString

public String toString()

Overrides:

toString in class Object

getBackLogStatistics

public IRedoLogStatistics getBackLogStatistics()

flushRedoLogToStorage

public int flushRedoLogToStorage()

Returns:

number of flushed packets

Since:

16.2

monitorState

public void monitorState(OperationWeightInfo info)

setNodeStateListener

public void setNodeStateListener(IReplicationNodeStateListener listener)

onTargetChannelOutOfSync

public boolean onTargetChannelOutOfSync(String groupName,
 String channelSourceLookupName,
 IncomingReplicationOutOfSyncException outOfSyncReason)

Description copied from interface: IReplicationTargetGroupStateListener

Called when a target channel failed handshake due to becoming out of sync

Specified by:

onTargetChannelOutOfSync in interface IReplicationTargetGroupStateListener

Returns:

true if the target channel is allowed to resync (and lose data due to resynchronization)

onTargetChannelBacklogDropped

public void onTargetChannelBacklogDropped(String groupName,
 String channelSourceLooString,
 IBacklogMemberState memberState)

Description copied from interface: IReplicationTargetGroupStateListener

Called when a target channel received a notice that its backlog was dropped at the source

Specified by:

onTargetChannelBacklogDropped in interface IReplicationTargetGroupStateListener

onTargetChannelCreationValidation

public void onTargetChannelCreationValidation(String groupName,
 String sourceMemberName,
 Object sourceUniqueId)

Description copied from interface: IReplicationTargetGroupStateListener

Called when a new channel is being established, just before the channel is created to allow custom validation logic. An exception will consider the channel creation is invalid, regular return will be considered as valid connection

Specified by:

onTargetChannelCreationValidation in interface IReplicationTargetGroupStateListener

onTargetChannelSourceDisconnected

public void onTargetChannelSourceDisconnected(String groupName,
 String sourceMemberName,
 Object sourceUniqueId)

Description copied from interface: IReplicationTargetGroupStateListener

Called when a target channel lost connection to its source

Specified by:

onTargetChannelSourceDisconnected in interface IReplicationTargetGroupStateListener

onTargetChannelConnected

public void onTargetChannelConnected(String groupName,
 String sourceMemberName,
 Object sourceUniqueId)

Description copied from interface: IReplicationTargetGroupStateListener

Called when a target channel is connected/created

Specified by:

onTargetChannelConnected in interface IReplicationTargetGroupStateListener

onSourceBrokenReplicationTopology

public void onSourceBrokenReplicationTopology(String groupName,
 String channelMemberName,
 BrokenReplicationTopologyException error)

Specified by:

onSourceBrokenReplicationTopology in interface IReplicationSourceGroupStateListener

onSourceChannelActivated

public void onSourceChannelActivated(String groupName,
 String memberName)

Specified by:

onSourceChannelActivated in interface IReplicationSourceGroupStateListener

onNewReplicaRequest

public void onNewReplicaRequest(String groupName,
 String channelName,
 boolean isSynchronizeRequest)

flushPendingReplication

public boolean flushPendingReplication(long timeout,
 TimeUnit units)

dumpState

public String dumpState()

getRouterAdmin

public IReplicationRouterAdmin getRouterAdmin()

setTag

public void setTag(String tag)

setBlobStoreReplicaConsumeHelper

public void setBlobStoreReplicaConsumeHelper(BlobStoreReplicaConsumeHelper blobStoreReplicaConsumeHelper)

Specified by:

setBlobStoreReplicaConsumeHelper in interface IReplicationNode

getBlobStoreReplicaConsumeHelper

public BlobStoreReplicaConsumeHelper getBlobStoreReplicaConsumeHelper()

Specified by:

getBlobStoreReplicaConsumeHelper in interface IReplicationNode

getDirectPesistencySyncHandler

public IDirectPersistencySyncHandler getDirectPesistencySyncHandler()

Specified by:

getDirectPesistencySyncHandler in interface IReplicationNode

getDirectPersistencyBackupSyncIteratorHandler

public DirectPersistencyBackupSyncIteratorHandler getDirectPersistencyBackupSyncIteratorHandler()

Specified by:

getDirectPersistencyBackupSyncIteratorHandler in interface IReplicationNode

setDirectPersistencyBackupSyncIteratorHandler

public void setDirectPersistencyBackupSyncIteratorHandler(DirectPersistencyBackupSyncIteratorHandler directPersistencyBackupSyncIteratorHandler)

Specified by:

setDirectPersistencyBackupSyncIteratorHandler in interface IReplicationNode

getMetricRegister

public MetricRegistrator getMetricRegister()

getReplicaHandler

public ReplicationNodeReplicaHandler getReplicaHandler()