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

Interface IReplicationGroupBacklog

All Superinterfaces:

DynamicSourceGroupConfigHolder.IDynamicSourceGroupStateListener

All Known Subinterfaces:

IReplicationAsyncGroupBacklog, IReplicationReliableAsyncGroupBacklog, IReplicationSyncGroupBacklog

All Known Implementing Classes:

AbstractGlobalOrderGroupBacklog, AbstractMultiBucketSingleFileGroupBacklog, AbstractMultiSourceSingleFileGroupBacklog, AbstractSingleFileGroupBacklog, GlobalOrderAsyncGroupBacklog, GlobalOrderReliableAsyncGroupBacklog, GlobalOrderSyncGroupBacklog, MultiBucketSingleFileReliableAsyncGroupBacklog, MultiBucketSingleFileSyncGroupBacklog, MultiSourceSingleFileAsyncGroupBacklog, MultiSourceSingleFileReliableAsyncGroupBacklog

public interface IReplicationGroupBacklog
extends DynamicSourceGroupConfigHolder.IDynamicSourceGroupStateListener

Holds the replication backlog of a single IReplicationSourceGroup

Since:

8.0

Author:

eitany

Method Summary

Modifier and Type	Method and Description
void	beginSynchronizing(String memberName)
void	beginSynchronizing(String memberName, boolean isDirectPersistencySync)
void	clearReplicated()
void	close()
void	decreaseWeight(String memberName, long fromKey, long toKey, AbstractSingleFileConfirmationHolder holder)
String	dumpState()
int	flushRedoLogToStorage()
void	freeWriteLock()
IProcessResult	fromWireForm(Object wiredProcessResult)
long	getConfirmed(String memberName)
IMarker	getCurrentMarker(String memberName) Returns a marker of the current last position of the backlog
IReplicationPacketDataProducer	getDataProducer()
IBacklogHandshakeRequest	getHandshakeRequest(String memberName, Object customBacklogMetadata)
IIdleStateData	getIdleStateData(String memberName, PlatformLogicalVersion targetMemberVersion)
IMarker	getMarker(IReplicationOrderedPacket packet, String membersGroupName)
IHandshakeIteration	getNextHandshakeIteration(String memberName, IHandshakeContext handshakeContext)
List<IReplicationOrderedPacket>	getPackets(String memberName, int maxSize, IReplicationChannelDataFilter filter, PlatformLogicalVersion targetMemberVersion, org.slf4j.Logger logger)
IReplicationOrderedPacket	getSpecificPacket(long packetKey) Gets a specific packet inside the backlog
IBacklogMemberState	getState(String memberName)
IRedoLogStatistics	getStatistics()
IMarker	getUnconfirmedMarker(String memberName) Returns a marker of the current unconfirmed packet of this given member
long	getWeight()
long	getWeight(String memberName)
void	increaseWeight(String memberName, long weight, AbstractSingleFileConfirmationHolder holder)
void	makeMemberConfirmedOnAll(String memberName) Called once a new member addition is known to the available keepers
boolean	mergeWithDiscarded(IReplicationOrderedPacket previousDiscardedPacket, IReplicationOrderedPacket mergedPacket, String memberName) Merge an already existing discarded packet with a new packet that should be discarded
void	monitor(OperationWeightInfo info)
void	performCompaction()
IHandshakeContext	processHandshakeResponse(String memberName, IBacklogHandshakeRequest request, IProcessLogHandshakeResponse response, PlatformLogicalVersion targetLogicalVersion, Object customBacklogMetadata)
void	processIdleStateDataResult(String memberName, IProcessResult result, IIdleStateData idleStateData)
void	processResult(String memberName, IProcessResult result, IReplicationOrderedPacket packet)
void	processResult(String memberName, IProcessResult result, List<IReplicationOrderedPacket> packets)
void	registerWith(MetricRegistrator metricRegister)
IReplicationOrderedPacket	replaceWithDiscarded(IReplicationOrderedPacket packet, boolean forceDiscard)
void	setGroupHistory(IReplicationGroupHistory groupHistory)
void	setPendingError(String memberName, Throwable error, IIdleStateData idleStateData)
void	setPendingError(String memberName, Throwable error, IReplicationOrderedPacket replicatedPacket)
void	setPendingError(String memberName, Throwable error, List<IReplicationOrderedPacket> replicatedPackets)
void	setStateListener(IReplicationBacklogStateListener stateListener)
long	size()
long	size(String memberName)
void	stopSynchronization(String memberName)
boolean	supportDiscardMerge()
void	synchronizationCopyStageDone(String memberName)
boolean	synchronizationDataGenerated(String memberName, String uid)
void	synchronizationDone(String memberName)
String	toLogMessage(String memberName)
void	writeLock()

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

memberAdded, memberRemoved

Method Detail

getHandshakeRequest

IBacklogHandshakeRequest getHandshakeRequest(String memberName,
                                             Object customBacklogMetadata)

processHandshakeResponse

IHandshakeContext processHandshakeResponse(String memberName,
                                           IBacklogHandshakeRequest request,
                                           IProcessLogHandshakeResponse response,
                                           PlatformLogicalVersion targetLogicalVersion,
                                           Object customBacklogMetadata)

getNextHandshakeIteration

IHandshakeIteration getNextHandshakeIteration(String memberName,
                                              IHandshakeContext handshakeContext)

size

long size(String memberName)

size

long size()

clearReplicated

void clearReplicated()

getState

IBacklogMemberState getState(String memberName)

processResult

void processResult(String memberName,
                   IProcessResult result,
                   List<IReplicationOrderedPacket> packets)
            throws ReplicationException

Throws:

ReplicationException

processResult

void processResult(String memberName,
                   IProcessResult result,
                   IReplicationOrderedPacket packet)
            throws ReplicationException

Throws:

ReplicationException

setPendingError

void setPendingError(String memberName,
                     Throwable error,
                     List<IReplicationOrderedPacket> replicatedPackets)

Since:

8.0.1

setPendingError

void setPendingError(String memberName,
                     Throwable error,
                     IReplicationOrderedPacket replicatedPacket)

Since:

8.0.1

setPendingError

void setPendingError(String memberName,
                     Throwable error,
                     IIdleStateData idleStateData)

Since:

9.0

getPackets

List<IReplicationOrderedPacket> getPackets(String memberName,
                                           int maxSize,
                                           IReplicationChannelDataFilter filter,
                                           PlatformLogicalVersion targetMemberVersion,
                                           org.slf4j.Logger logger)

beginSynchronizing

void beginSynchronizing(String memberName)

beginSynchronizing

void beginSynchronizing(String memberName,
                        boolean isDirectPersistencySync)

synchronizationDataGenerated

boolean synchronizationDataGenerated(String memberName,
                                     String uid)

synchronizationCopyStageDone

void synchronizationCopyStageDone(String memberName)

synchronizationDone

void synchronizationDone(String memberName)

stopSynchronization

void stopSynchronization(String memberName)

getCurrentMarker

IMarker getCurrentMarker(String memberName)

Returns a marker of the current last position of the backlog

Parameters:

memberName - the member we wish this marker will be attached to

getUnconfirmedMarker

IMarker getUnconfirmedMarker(String memberName)

Returns a marker of the current unconfirmed packet of this given member

Parameters:

memberName - the member we wish this marker will be attached to

getMarker

IMarker getMarker(IReplicationOrderedPacket packet,
                  String membersGroupName)

getDataProducer

IReplicationPacketDataProducer getDataProducer()

Returns:

the data producer this group backlog is using to generate replication data

replaceWithDiscarded

IReplicationOrderedPacket replaceWithDiscarded(IReplicationOrderedPacket packet,
                                               boolean forceDiscard)

mergeWithDiscarded

boolean mergeWithDiscarded(IReplicationOrderedPacket previousDiscardedPacket,
                           IReplicationOrderedPacket mergedPacket,
                           String memberName)

Merge an already existing discarded packet with a new packet that should be discarded

Parameters:

previousDiscardedPacket - the already existing discarded packet which is a result replaceWithDiscarded(IReplicationOrderedPacket, boolean)

mergedPacket - the new packet that needs to be discarded and merged into the existing discarded packet

memberName - TODO

Returns:

return true if merge is successful, false otherwise

makeMemberConfirmedOnAll

void makeMemberConfirmedOnAll(String memberName)

Called once a new member addition is known to the available keepers

Parameters:

memberName - new member name

supportDiscardMerge

boolean supportDiscardMerge()

getStatistics

IRedoLogStatistics getStatistics()

flushRedoLogToStorage

int flushRedoLogToStorage()

Returns:

number of flushed packets

Since:

16.2

monitor

void monitor(OperationWeightInfo info)
      throws RedoLogCapacityExceededException

Throws:

RedoLogCapacityExceededException

toLogMessage

String toLogMessage(String memberName)

dumpState

String dumpState()

close

void close()

setGroupHistory

void setGroupHistory(IReplicationGroupHistory groupHistory)

setStateListener

void setStateListener(IReplicationBacklogStateListener stateListener)

fromWireForm

IProcessResult fromWireForm(Object wiredProcessResult)

getSpecificPacket

IReplicationOrderedPacket getSpecificPacket(long packetKey)

Gets a specific packet inside the backlog

Since:

9.0

getIdleStateData

IIdleStateData getIdleStateData(String memberName,
                                PlatformLogicalVersion targetMemberVersion)

processIdleStateDataResult

void processIdleStateDataResult(String memberName,
                                IProcessResult result,
                                IIdleStateData idleStateData)
                         throws ReplicationException

Throws:

ReplicationException

registerWith

void registerWith(MetricRegistrator metricRegister)

getConfirmed

long getConfirmed(String memberName)

writeLock

void writeLock()

freeWriteLock

void freeWriteLock()

getWeight

long getWeight()

getWeight

long getWeight(String memberName)

increaseWeight

void increaseWeight(String memberName,
                    long weight,
                    AbstractSingleFileConfirmationHolder holder)

decreaseWeight

void decreaseWeight(String memberName,
                    long fromKey,
                    long toKey,
                    AbstractSingleFileConfirmationHolder holder)

performCompaction

void performCompaction()