com.gigaspaces.internal.cluster.node.impl.groups

Interface IReplicationTargetGroup

All Known Implementing Classes:

AbstractAsyncReplicationTargetGroup, AbstractReplicationTargetGroup, AbstractSyncReplicationTargetGroup, AbstractSyncSingleOriginReplicationTargetGroup, AsyncMultiOriginReplicationTargetGroup, AsyncSingleOriginReplicationTargetGroup, ReliableAsyncKeeperReplicationTargetGroup, ReliableAsyncSingleOriginReplicationTargetGroup, SyncMultiOriginReplicationTargetGroup, SyncSingleOriginReplicationTargetGroup

public interface IReplicationTargetGroup

Handle incoming replication from one or more IReplicationSourceGroup

Since:

8.0

Author:

eitany

Method Summary

Modifier and Type	Method and Description
void	addSynchronizeState(String sourceMemberLookupName, SpaceReplicaState result)
void	close() Close this replication group, once closed it can no longer be used
ConnectChannelHandshakeResponse	connectChannel(RouterStubHolder sourceRouterStubHolder, ConnectChannelHandshakeRequest handshakeRequest) Connect a IReplicationSourceChannel to this group.
String	dumpState()
IReplicationTargetChannel	getChannel(String sourceMemberLookupName)
String	getGroupName()
long	getLastProcessTimeStamp(String replicaSourceLookupName)
void	onChannelBacklogDropped(String sourceMemberLookupName, Object sourceUniqueId, IBacklogMemberState memberState)
Object	process(String sourceMemberLookupName, Object sourceUniqueId, IReplicationOrderedPacket packet)
Object	processBatch(String sourceMemberLookupName, Object sourceUniqueId, List<IReplicationOrderedPacket> packets)
void	processHandshakeIteration(String sourceMemberLookupName, Object sourceUniqueId, IHandshakeIteration handshakeIteration)
Object	processIdleStateData(String sourceMemberLookupName, Object sourceUniqueId, IIdleStateData idleStateData)
void	processUnreliableOperation(String sourceMemberLookupName, Object sourceUniqueId, IReplicationUnreliableOperation operation)
void	setActive()
void	setPassive()
void	synchronizationDone(String sourceMemberLookupName, Object sourceUniqueId)

Method Detail

close

void close()

Close this replication group, once closed it can no longer be used

connectChannel

ConnectChannelHandshakeResponse connectChannel(RouterStubHolder sourceRouterStubHolder,
                                               ConnectChannelHandshakeRequest handshakeRequest)

Connect a IReplicationSourceChannel to this group. The success or failure of this operation is indicated by the result IProcessLogHandshakeResponse

Parameters:

handshakeRequest - the handshake related details

Returns:

The success or failure of this operation is indicated by the result IProcessLogHandshakeResponse

onChannelBacklogDropped

void onChannelBacklogDropped(String sourceMemberLookupName,
                             Object sourceUniqueId,
                             IBacklogMemberState memberState)

processHandshakeIteration

void processHandshakeIteration(String sourceMemberLookupName,
                               Object sourceUniqueId,
                               IHandshakeIteration handshakeIteration)

processBatch

Object processBatch(String sourceMemberLookupName,
                    Object sourceUniqueId,
                    List<IReplicationOrderedPacket> packets)

process

Object process(String sourceMemberLookupName,
               Object sourceUniqueId,
               IReplicationOrderedPacket packet)

processUnreliableOperation

void processUnreliableOperation(String sourceMemberLookupName,
                                Object sourceUniqueId,
                                IReplicationUnreliableOperation operation)

processIdleStateData

Object processIdleStateData(String sourceMemberLookupName,
                            Object sourceUniqueId,
                            IIdleStateData idleStateData)

addSynchronizeState

void addSynchronizeState(String sourceMemberLookupName,
                         SpaceReplicaState result)

synchronizationDone

void synchronizationDone(String sourceMemberLookupName,
                         Object sourceUniqueId)

getLastProcessTimeStamp

long getLastProcessTimeStamp(String replicaSourceLookupName)

getGroupName

String getGroupName()

setActive

void setActive()

setPassive

void setPassive()

dumpState

String dumpState()

getChannel

IReplicationTargetChannel getChannel(String sourceMemberLookupName)