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

Class ReplicationSettings

java.lang.Object

com.gigaspaces.internal.cluster.node.impl.config.ReplicationSettings

All Implemented Interfaces:

IReplicationSettings, ISyncReplicationSettings

Direct Known Subclasses:

MirrorChannelReplicationSettings, SpaceReplicationSettings

public class ReplicationSettings
extends Object
implements IReplicationSettings, ISyncReplicationSettings

Constructor Summary

Constructors

Constructor	Description
ReplicationSettings()

Method Summary

Modifier and Type	Method	Description
String	getBacklogWeightPolicy()
int	getBatchParallelFactor()
int	getBatchParallelThreshold()
int	getBatchSize()
short	getBucketCount()
ConsistencyLevel	getConsistencyLevel()
long	getConsumeTimeout()
long	getIdleDelay()
IReplicationInFilter	getInFilter()
BacklogConfig.LimitReachedPolicy	getLimitReachedPolicy()
long	getMaxRedoLogCapacity()
long	getMaxRedoLogCapacityDuringRecovery()
long	getMaxRedoLogMemoryCapacity()
int	getMaxThrottleTPWhenInactive()
int	getMinThrottleTPWhenActive()
int	getOperationsReplicationThreshold()
IReplicationOutFilter	getOutFilter()
ReplicationProcessingType	getProcessingType()
RedoLogCompaction	getRedoLogCompaction()
ISpaceCopyReplicaInFilter	getSpaceCopyInFilter()
ISpaceCopyReplicaOutFilter	getSpaceCopyOutFilter()
SwapBacklogConfig	getSwapBacklogSettings()
ISyncReplicationSettings	getSyncReplicationSettings()
boolean	isNetworkCompressionEnabled()
boolean	isOneWay()
boolean	isThrottleWhenInactive()
void	setBacklogWeightPolicy(String backlogWeightPolicy)
void	setBatchParallelFactor(int batchParallelFactor)
void	setBatchParallelThreshold(int batchParallelThreshold)
void	setBatchSize(int batchSize)
void	setBucketCount(short bucketCount)
void	setConsumeTimeout(long consumeTimeout)
void	setIdleDelay(long replicationInterval)
void	setLimitReachedPolicy(BacklogConfig.LimitReachedPolicy limitReachedPloicy)
void	setMaxRedoLogCapacity(long maxRedoLogCapacity)
void	setMaxRedoLogCapacityDuringRecovery(long maxRedoLogCapacityDuringRecovery)
void	setMaxRedoLogMemoryCapacity(long maxRedoLogMemoryCapacity)
void	setMaxThrottleTPWhenInactive(int maxThrottleTPWhenInactive)
void	setMinThrottleTPWhenActive(int minThrottleTPWhenActive)
void	setOneWay(boolean isOneWay)
void	setOperationsReplicationThreshold(int operationsReplicationThreshold)
void	setProcessindType(ReplicationProcessingType processindType)
void	setRedoLogCompaction(RedoLogCompaction redoLogCompaction)
void	setThrottleWhenInactive(boolean throttleWhenInactive)

Methods inherited from class java.lang.Object

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

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

isOnRecoveryRedoLogExceededBlockPrimary

Constructor Details

ReplicationSettings

public ReplicationSettings()

Method Details

getOperationsReplicationThreshold

public int getOperationsReplicationThreshold()

Specified by:

getOperationsReplicationThreshold in interface IReplicationSettings

setOperationsReplicationThreshold

public void setOperationsReplicationThreshold(int operationsReplicationThreshold)

getIdleDelay

public long getIdleDelay()

Specified by:

getIdleDelay in interface IReplicationSettings

setIdleDelay

public void setIdleDelay(long replicationInterval)

getLimitReachedPolicy

public BacklogConfig.LimitReachedPolicy getLimitReachedPolicy()

Specified by:

getLimitReachedPolicy in interface IReplicationSettings

setLimitReachedPolicy

public void setLimitReachedPolicy(BacklogConfig.LimitReachedPolicy limitReachedPloicy)

getMaxRedoLogCapacity

public long getMaxRedoLogCapacity()

Specified by:

getMaxRedoLogCapacity in interface IReplicationSettings

setMaxRedoLogCapacity

public void setMaxRedoLogCapacity(long maxRedoLogCapacity)

getMaxRedoLogCapacityDuringRecovery

public long getMaxRedoLogCapacityDuringRecovery()

setMaxRedoLogCapacityDuringRecovery

public void setMaxRedoLogCapacityDuringRecovery(long maxRedoLogCapacityDuringRecovery)

getMaxRedoLogMemoryCapacity

public long getMaxRedoLogMemoryCapacity()

setMaxRedoLogMemoryCapacity

public void setMaxRedoLogMemoryCapacity(long maxRedoLogMemoryCapacity)

getBatchSize

public int getBatchSize()

Specified by:

getBatchSize in interface IReplicationSettings

setBatchSize

public void setBatchSize(int batchSize)

isOneWay

public boolean isOneWay()

setOneWay

public void setOneWay(boolean isOneWay)

getInFilter

public IReplicationInFilter getInFilter()

Specified by:

getInFilter in interface IReplicationSettings

getOutFilter

public IReplicationOutFilter getOutFilter()

Specified by:

getOutFilter in interface IReplicationSettings

getSpaceCopyInFilter

public ISpaceCopyReplicaInFilter getSpaceCopyInFilter()

Specified by:

getSpaceCopyInFilter in interface IReplicationSettings

getSpaceCopyOutFilter

public ISpaceCopyReplicaOutFilter getSpaceCopyOutFilter()

Specified by:

getSpaceCopyOutFilter in interface IReplicationSettings

getSyncReplicationSettings

public ISyncReplicationSettings getSyncReplicationSettings()

Specified by:

getSyncReplicationSettings in interface IReplicationSettings

isThrottleWhenInactive

public boolean isThrottleWhenInactive()

Specified by:

isThrottleWhenInactive in interface ISyncReplicationSettings

setThrottleWhenInactive

public void setThrottleWhenInactive(boolean throttleWhenInactive)

getMaxThrottleTPWhenInactive

public int getMaxThrottleTPWhenInactive()

Specified by:

getMaxThrottleTPWhenInactive in interface ISyncReplicationSettings

setMaxThrottleTPWhenInactive

public void setMaxThrottleTPWhenInactive(int maxThrottleTPWhenInactive)

getMinThrottleTPWhenActive

public int getMinThrottleTPWhenActive()

Specified by:

getMinThrottleTPWhenActive in interface ISyncReplicationSettings

setMinThrottleTPWhenActive

public void setMinThrottleTPWhenActive(int minThrottleTPWhenActive)

setProcessindType

public void setProcessindType(ReplicationProcessingType processindType)

getProcessingType

public ReplicationProcessingType getProcessingType()

Specified by:

getProcessingType in interface IReplicationSettings

setBucketCount

public void setBucketCount(short bucketCount)

getBucketCount

public short getBucketCount()

Specified by:

getBucketCount in interface IReplicationSettings

setBatchParallelFactor

public void setBatchParallelFactor(int batchParallelFactor)

getBatchParallelFactor

public int getBatchParallelFactor()

Specified by:

getBatchParallelFactor in interface IReplicationSettings

setBatchParallelThreshold

public void setBatchParallelThreshold(int batchParallelThreshold)

getBatchParallelThreshold

public int getBatchParallelThreshold()

Specified by:

getBatchParallelThreshold in interface IReplicationSettings

getConsumeTimeout

public long getConsumeTimeout()

Specified by:

getConsumeTimeout in interface IReplicationSettings

setConsumeTimeout

public void setConsumeTimeout(long consumeTimeout)

getSwapBacklogSettings

public SwapBacklogConfig getSwapBacklogSettings()

Specified by:

getSwapBacklogSettings in interface IReplicationSettings

getBacklogWeightPolicy

public String getBacklogWeightPolicy()

Specified by:

getBacklogWeightPolicy in interface IReplicationSettings

getRedoLogCompaction

public RedoLogCompaction getRedoLogCompaction()

Specified by:

getRedoLogCompaction in interface IReplicationSettings

isNetworkCompressionEnabled

public boolean isNetworkCompressionEnabled()

Specified by:

isNetworkCompressionEnabled in interface IReplicationSettings

setRedoLogCompaction

public void setRedoLogCompaction(RedoLogCompaction redoLogCompaction)

setBacklogWeightPolicy

public void setBacklogWeightPolicy(String backlogWeightPolicy)

getConsistencyLevel

public ConsistencyLevel getConsistencyLevel()

Specified by:

getConsistencyLevel in interface ISyncReplicationSettings