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

Class ReplicationOutContext

java.lang.Object

com.gigaspaces.internal.utils.threadlocal.AbstractResource

com.gigaspaces.internal.cluster.node.impl.ReplicationOutContext

All Implemented Interfaces:

IReplicationOutContext, Iterable<IReplicationGroupOutContext>

public class ReplicationOutContext
extends AbstractResource
implements IReplicationOutContext, Iterable<IReplicationGroupOutContext>

Field Summary

Fields

Modifier and Type	Field	Description
OperationID[]	_operationIDs
Map<String,Object>	_partialUpdatesAndInPlaceUpdatesInfo
boolean[]	_shouldReplicate

Constructor Summary

Constructors

Constructor	Description
ReplicationOutContext()

Method Summary

Modifier and Type	Method	Description
void	askForMarker(String membersGroupName)
void	blobstorePendingReplicationBulk()
protected void	clean()
String	getAskedMarker()
int	getBlobstoreReplicationBulkId()
int	getCompleted()
IDirectPersistencyOpInfo	getDirectPersistencyPendingEntry()
IDirectPersistencySyncHandler	getDirectPesistencySyncHandler()
IReplicationGroupOutContext	getGroupContext(String groupName)
GroupMapping	getGroupMapping()
MVCCGenerationsState	getMVCCGenerationsState()
OperationID	getOperationID()
OperationID[]	getOperationIDs()
boolean[]	getPartialUpdatedValuesIndicators()
Map<String,Object>	getPartialUpdatesAndInPlaceUpdatesInfo()
IEntryData	getPreviousUpdatedEntryData()
IMarker	getRequestedMarker()
boolean[]	getShouldReplicate()
IReplicationGroupOutContext	getSingleGroupParticipantContext()
Collection<SpaceEntryMutator>	getSpaceEntryMutators()
boolean	isBackupOnly()
boolean	isBlobstorePendingReplicationBulk()
boolean	isEmpty()
boolean	isFromGateway()
boolean	isMvccRevertGenerationTxn()
boolean	isOverrideVersion(String uid)
boolean	isSingleGroupParticipant()
Iterator<IReplicationGroupOutContext>	iterator()
int	pendingSize()
void	setBackupOnly(boolean backupOnly)
void	setBlobstoreReplicationBulkId(int blobstoreBulkId)
int	setCompleted(int completed)
void	setDirectPersistencyPendingEntry(IDirectPersistencyOpInfo directPesistencyEntry)
void	setDirectPesistencySyncHandler(IDirectPersistencySyncHandler directPesistencySyncHandler)
void	setFromGateway(boolean fromGateway)
void	setGroupContext(IReplicationGroupOutContext groupContext)
void	setGroupMapping(GroupMapping mapping)
void	setMarker(IMarker marker)
void	setMVCCGenerationsState(MVCCGenerationsState mvccGenerationsState)
void	setMvccRevertGenerationTxn(boolean isMvccRevertGenerationTxn)
void	setOperationID(OperationID operationID)
void	setOperationIDs(OperationID[] operationIDs)
void	setOverrideVersionUids(Set<String> overrideVersionUids)
void	setPartialUpdatedValuesIndicators(boolean[] partialUpdatedValuesIndicators)
void	setPartialUpdatesInfo(Map<String,Object> partialUpdatesAndInPlaceUpdatesInfo)
void	setPreviousUpdatedEntryData(IEntryData PreviousUpdatedEntryData)
void	setShouldReplicate(boolean[] shouldReplicate)
void	setSpaceEntryMutators(Collection<SpaceEntryMutator> spaceEntryMutators)
String	toString()

Methods inherited from class com.gigaspaces.internal.utils.threadlocal.AbstractResource

isAvaliable, release, setAvaliable

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.gigaspaces.internal.cluster.node.IReplicationOutContext

release

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Field Details

_shouldReplicate

public boolean[] _shouldReplicate

_partialUpdatesAndInPlaceUpdatesInfo

public Map<String,Object> _partialUpdatesAndInPlaceUpdatesInfo

_operationIDs

public OperationID[] _operationIDs

Constructor Details

ReplicationOutContext

public ReplicationOutContext()

Method Details

getGroupContext

public IReplicationGroupOutContext getGroupContext(String groupName)

clean

protected void clean()

Specified by:

clean in class AbstractResource

setGroupContext

public void setGroupContext(IReplicationGroupOutContext groupContext)

isSingleGroupParticipant

public boolean isSingleGroupParticipant()

isEmpty

public boolean isEmpty()

getSingleGroupParticipantContext

public IReplicationGroupOutContext getSingleGroupParticipantContext()

iterator

public Iterator<IReplicationGroupOutContext> iterator()

Specified by:

iterator in interface Iterable<IReplicationGroupOutContext>

getGroupMapping

public GroupMapping getGroupMapping()

setGroupMapping

public void setGroupMapping(GroupMapping mapping)

getOperationID

public OperationID getOperationID()

setOperationID

public void setOperationID(OperationID operationID)

getPartialUpdatedValuesIndicators

public boolean[] getPartialUpdatedValuesIndicators()

setPartialUpdatedValuesIndicators

public void setPartialUpdatedValuesIndicators(boolean[] partialUpdatedValuesIndicators)

getShouldReplicate

public boolean[] getShouldReplicate()

setShouldReplicate

public void setShouldReplicate(boolean[] shouldReplicate)

getPartialUpdatesAndInPlaceUpdatesInfo

public Map<String,Object> getPartialUpdatesAndInPlaceUpdatesInfo()

setPartialUpdatesInfo

public void setPartialUpdatesInfo(Map<String,Object> partialUpdatesAndInPlaceUpdatesInfo)

getOperationIDs

public OperationID[] getOperationIDs()

setOperationIDs

public void setOperationIDs(OperationID[] operationIDs)

isFromGateway

public boolean isFromGateway()

setFromGateway

public void setFromGateway(boolean fromGateway)

pendingSize

public int pendingSize()

Specified by:

pendingSize in interface IReplicationOutContext

setOverrideVersionUids

public void setOverrideVersionUids(Set<String> overrideVersionUids)

isOverrideVersion

public boolean isOverrideVersion(String uid)

setPreviousUpdatedEntryData

public void setPreviousUpdatedEntryData(IEntryData PreviousUpdatedEntryData)

getPreviousUpdatedEntryData

public IEntryData getPreviousUpdatedEntryData()

setSpaceEntryMutators

public void setSpaceEntryMutators(Collection<SpaceEntryMutator> spaceEntryMutators)

getSpaceEntryMutators

public Collection<SpaceEntryMutator> getSpaceEntryMutators()

askForMarker

public void askForMarker(String membersGroupName)

Specified by:

askForMarker in interface IReplicationOutContext

getRequestedMarker

public IMarker getRequestedMarker()

Specified by:

getRequestedMarker in interface IReplicationOutContext

getAskedMarker

public String getAskedMarker()

setMarker

public void setMarker(IMarker marker)

setCompleted

public int setCompleted(int completed)

Specified by:

setCompleted in interface IReplicationOutContext

getCompleted

public int getCompleted()

Specified by:

getCompleted in interface IReplicationOutContext

setDirectPersistencyPendingEntry

public void setDirectPersistencyPendingEntry(IDirectPersistencyOpInfo directPesistencyEntry)

Specified by:

setDirectPersistencyPendingEntry in interface IReplicationOutContext

getDirectPersistencyPendingEntry

public IDirectPersistencyOpInfo getDirectPersistencyPendingEntry()

Specified by:

getDirectPersistencyPendingEntry in interface IReplicationOutContext

getDirectPesistencySyncHandler

public IDirectPersistencySyncHandler getDirectPesistencySyncHandler()

Specified by:

getDirectPesistencySyncHandler in interface IReplicationOutContext

setDirectPesistencySyncHandler

public void setDirectPesistencySyncHandler(IDirectPersistencySyncHandler directPesistencySyncHandler)

Specified by:

setDirectPesistencySyncHandler in interface IReplicationOutContext

getBlobstoreReplicationBulkId

public int getBlobstoreReplicationBulkId()

Specified by:

getBlobstoreReplicationBulkId in interface IReplicationOutContext

setBlobstoreReplicationBulkId

public void setBlobstoreReplicationBulkId(int blobstoreBulkId)

Specified by:

setBlobstoreReplicationBulkId in interface IReplicationOutContext

isBlobstorePendingReplicationBulk

public boolean isBlobstorePendingReplicationBulk()

Specified by:

isBlobstorePendingReplicationBulk in interface IReplicationOutContext

blobstorePendingReplicationBulk

public void blobstorePendingReplicationBulk()

Specified by:

blobstorePendingReplicationBulk in interface IReplicationOutContext

isBackupOnly

public boolean isBackupOnly()

setBackupOnly

public void setBackupOnly(boolean backupOnly)

getMVCCGenerationsState

public MVCCGenerationsState getMVCCGenerationsState()

Specified by:

getMVCCGenerationsState in interface IReplicationOutContext

setMVCCGenerationsState

public void setMVCCGenerationsState(MVCCGenerationsState mvccGenerationsState)

Specified by:

setMVCCGenerationsState in interface IReplicationOutContext

isMvccRevertGenerationTxn

public boolean isMvccRevertGenerationTxn()

Specified by:

isMvccRevertGenerationTxn in interface IReplicationOutContext

setMvccRevertGenerationTxn

public void setMvccRevertGenerationTxn(boolean isMvccRevertGenerationTxn)

Specified by:

setMvccRevertGenerationTxn in interface IReplicationOutContext

toString

public String toString()

Overrides:

toString in class Object