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

Class ReplicationSettingsAdapter

java.lang.Object

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

All Implemented Interfaces:

IReplicationSettings, ISpaceReplicationSettings, ISyncReplicationSettings

public class ReplicationSettingsAdapter
extends Object
implements ISpaceReplicationSettings, ISyncReplicationSettings

Constructor Summary

Constructors

Constructor	Description
ReplicationSettingsAdapter(ReplicationPolicy policy, ReplicationFilterManager filterManager)

Method Summary

Modifier and Type	Method	Description
String	getBacklogWeightPolicy()
int	getBatchParallelFactor()
int	getBatchParallelThreshold()
int	getBatchSize()
short	getBucketCount()
ConsistencyLevel	getConsistencyLevel()
long	getConsumeTimeout()
List<String>	getGroupMemberNames()
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()
String	getSpaceMemberName()
SwapBacklogConfig	getSwapBacklogSettings()
ISyncReplicationSettings	getSyncReplicationSettings()
boolean	isMirrorServiceEnabled()
boolean	isNetworkCompressionEnabled()
boolean	isOneWay()
boolean	isOnRecoveryRedoLogExceededBlockPrimary()
boolean	isReliableAsyncRepl()
boolean	isSync()
boolean	isThrottleWhenInactive()

Methods inherited from class java.lang.Object

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

Constructor Details

ReplicationSettingsAdapter

public ReplicationSettingsAdapter(ReplicationPolicy policy,
 ReplicationFilterManager filterManager)

Method Details

getSpaceMemberName

public String getSpaceMemberName()

Specified by:

getSpaceMemberName in interface ISpaceReplicationSettings

getGroupMemberNames

public List<String> getGroupMemberNames()

Specified by:

getGroupMemberNames in interface ISpaceReplicationSettings

getIdleDelay

public long getIdleDelay()

Specified by:

getIdleDelay in interface IReplicationSettings

getOperationsReplicationThreshold

public int getOperationsReplicationThreshold()

Specified by:

getOperationsReplicationThreshold in interface IReplicationSettings

getLimitReachedPolicy

public BacklogConfig.LimitReachedPolicy getLimitReachedPolicy()

Specified by:

getLimitReachedPolicy in interface IReplicationSettings

getMaxRedoLogCapacity

public long getMaxRedoLogCapacity()

Specified by:

getMaxRedoLogCapacity in interface IReplicationSettings

getMaxRedoLogCapacityDuringRecovery

public long getMaxRedoLogCapacityDuringRecovery()

Specified by:

getMaxRedoLogCapacityDuringRecovery in interface ISpaceReplicationSettings

getMaxRedoLogMemoryCapacity

public long getMaxRedoLogMemoryCapacity()

Specified by:

getMaxRedoLogMemoryCapacity in interface ISpaceReplicationSettings

getRedoLogCompaction

public RedoLogCompaction getRedoLogCompaction()

Specified by:

getRedoLogCompaction in interface IReplicationSettings

isNetworkCompressionEnabled

public boolean isNetworkCompressionEnabled()

Specified by:

isNetworkCompressionEnabled in interface IReplicationSettings

isOnRecoveryRedoLogExceededBlockPrimary

public boolean isOnRecoveryRedoLogExceededBlockPrimary()

Specified by:

isOnRecoveryRedoLogExceededBlockPrimary in interface IReplicationSettings

getBacklogWeightPolicy

public String getBacklogWeightPolicy()

Specified by:

getBacklogWeightPolicy in interface IReplicationSettings

isReliableAsyncRepl

public boolean isReliableAsyncRepl()

isMirrorServiceEnabled

public boolean isMirrorServiceEnabled()

isSync

public boolean isSync()

getBatchSize

public int getBatchSize()

Specified by:

getBatchSize in interface IReplicationSettings

isOneWay

public boolean isOneWay()

getOutFilter

public IReplicationOutFilter getOutFilter()

Specified by:

getOutFilter in interface IReplicationSettings

getInFilter

public IReplicationInFilter getInFilter()

Specified by:

getInFilter in interface IReplicationSettings

getSpaceCopyOutFilter

public ISpaceCopyReplicaOutFilter getSpaceCopyOutFilter()

Specified by:

getSpaceCopyOutFilter in interface IReplicationSettings

getSpaceCopyInFilter

public ISpaceCopyReplicaInFilter getSpaceCopyInFilter()

Specified by:

getSpaceCopyInFilter in interface IReplicationSettings

getSyncReplicationSettings

public ISyncReplicationSettings getSyncReplicationSettings()

Specified by:

getSyncReplicationSettings in interface IReplicationSettings

isThrottleWhenInactive

public boolean isThrottleWhenInactive()

Specified by:

isThrottleWhenInactive in interface ISyncReplicationSettings

getMaxThrottleTPWhenInactive

public int getMaxThrottleTPWhenInactive()

Specified by:

getMaxThrottleTPWhenInactive in interface ISyncReplicationSettings

getMinThrottleTPWhenActive

public int getMinThrottleTPWhenActive()

Specified by:

getMinThrottleTPWhenActive in interface ISyncReplicationSettings

getProcessingType

public ReplicationProcessingType getProcessingType()

Specified by:

getProcessingType in interface IReplicationSettings

getBucketCount

public short getBucketCount()

Specified by:

getBucketCount in interface IReplicationSettings

getBatchParallelFactor

public int getBatchParallelFactor()

Specified by:

getBatchParallelFactor in interface IReplicationSettings

getBatchParallelThreshold

public int getBatchParallelThreshold()

Specified by:

getBatchParallelThreshold in interface IReplicationSettings

getConsumeTimeout

public long getConsumeTimeout()

Specified by:

getConsumeTimeout in interface IReplicationSettings

getSwapBacklogSettings

public SwapBacklogConfig getSwapBacklogSettings()

Specified by:

getSwapBacklogSettings in interface IReplicationSettings

getConsistencyLevel

public ConsistencyLevel getConsistencyLevel()

Specified by:

getConsistencyLevel in interface ISyncReplicationSettings