com.gigaspaces.internal.cluster.node.impl.backlog.reliableasync

Interface IReplicationReliableAsyncGroupBacklog

All Superinterfaces:

DynamicSourceGroupConfigHolder.IDynamicSourceGroupStateListener, IReplicationGroupBacklog

All Known Implementing Classes:

GlobalOrderReliableAsyncGroupBacklog, MultiBucketSingleFileReliableAsyncGroupBacklog, MultiSourceSingleFileReliableAsyncGroupBacklog

public interface IReplicationReliableAsyncGroupBacklog
extends IReplicationGroupBacklog

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	IReplicationReliableAsyncGroupBacklog.KeeperMemberState

Method Summary

Modifier and Type	Method and Description
void	add(ReliableAsyncReplicationGroupOutContext groupContext, IEntryHolder entryHolder, ReplicationSingleOperationType operationType)
void	addGeneric(ReliableAsyncReplicationGroupOutContext groupContext, Object operationData, ReplicationSingleOperationType operationType)
void	addTransaction(ReliableAsyncReplicationGroupOutContext groupContext, ServerTransaction transaction, ArrayList<IEntryHolder> lockedEntries, ReplicationMultipleOperationType operationType)
void	afterHandshake(IProcessLogHandshakeResponse handshakeResponse) Called after handshake is done with the keeper target group
IReliableAsyncState	getEntireReliableAsyncState()
List<IReplicationOrderedPacket>	getReliableAsyncPackets(String memberName, int maxSize, IReplicationReliableAsyncGroupBacklog.KeeperMemberState[] keeperMembersState, IReplicationChannelDataFilter dataFilter, PlatformLogicalVersion targetMemberVersion, org.slf4j.Logger logger) Gets the next packet for the specified async member that is part of a reliable async group
IReliableAsyncState	getReliableAsyncState(String targetMemberName)
void	reliableAsyncSourceAdd(String sourceMemberName, IReplicationOrderedPacket packet)
void	reliableAsyncSourceKeep(String sourceMemberName, IReplicationOrderedPacket packet) Keep an already existing packet which was previously processed or will not be processed by the corresponding process log
void	updateReliableAsyncState(IReliableAsyncState reliableAsyncState, String sourceMemberName)

Methods inherited from interface com.gigaspaces.internal.cluster.node.impl.backlog.IReplicationGroupBacklog

beginSynchronizing, beginSynchronizing, clearReplicated, close, decreaseWeight, dumpState, flushRedoLogToStorage, freeWriteLock, fromWireForm, getConfirmed, getCurrentMarker, getDataProducer, getHandshakeRequest, getIdleStateData, getMarker, getNextHandshakeIteration, getPackets, getSpecificPacket, getState, getStatistics, getUnconfirmedMarker, getWeight, getWeight, increaseWeight, makeMemberConfirmedOnAll, mergeWithDiscarded, monitor, performCompaction, processHandshakeResponse, processIdleStateDataResult, processResult, processResult, registerWith, replaceWithDiscarded, setGroupHistory, setPendingError, setPendingError, setPendingError, setStateListener, size, size, stopSynchronization, supportDiscardMerge, synchronizationCopyStageDone, synchronizationDataGenerated, synchronizationDone, toLogMessage, writeLock

Methods inherited from interface com.gigaspaces.internal.cluster.node.impl.config.DynamicSourceGroupConfigHolder.IDynamicSourceGroupStateListener

memberAdded, memberRemoved

Method Detail

add

void add(ReliableAsyncReplicationGroupOutContext groupContext,
         IEntryHolder entryHolder,
         ReplicationSingleOperationType operationType)

addGeneric

void addGeneric(ReliableAsyncReplicationGroupOutContext groupContext,
                Object operationData,
                ReplicationSingleOperationType operationType)

addTransaction

void addTransaction(ReliableAsyncReplicationGroupOutContext groupContext,
                    ServerTransaction transaction,
                    ArrayList<IEntryHolder> lockedEntries,
                    ReplicationMultipleOperationType operationType)

reliableAsyncSourceAdd

void reliableAsyncSourceAdd(String sourceMemberName,
                            IReplicationOrderedPacket packet)

reliableAsyncSourceKeep

void reliableAsyncSourceKeep(String sourceMemberName,
                             IReplicationOrderedPacket packet)

Keep an already existing packet which was previously processed or will not be processed by the corresponding process log

getEntireReliableAsyncState

IReliableAsyncState getEntireReliableAsyncState()

getReliableAsyncState

IReliableAsyncState getReliableAsyncState(String targetMemberName)

updateReliableAsyncState

void updateReliableAsyncState(IReliableAsyncState reliableAsyncState,
                              String sourceMemberName)
                       throws NoSuchReplicationMemberException,
                              MissingReliableAsyncTargetStateException

Throws:

NoSuchReplicationMemberException

MissingReliableAsyncTargetStateException

getReliableAsyncPackets

List<IReplicationOrderedPacket> getReliableAsyncPackets(String memberName,
                                                        int maxSize,
                                                        IReplicationReliableAsyncGroupBacklog.KeeperMemberState[] keeperMembersState,
                                                        IReplicationChannelDataFilter dataFilter,
                                                        PlatformLogicalVersion targetMemberVersion,
                                                        org.slf4j.Logger logger)

Gets the next packet for the specified async member that is part of a reliable async group

Parameters:

keeperMembersState - the state of the keeper sync member

afterHandshake

void afterHandshake(IProcessLogHandshakeResponse handshakeResponse)

Called after handshake is done with the keeper target group