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

Class BacklogConfig

java.lang.Object

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

Direct Known Subclasses:

GlobalOrderBacklogConfig, MultiBucketSingleFileBacklogConfig, MultiSourceSingleFileBacklogConfig

public class BacklogConfig
extends Object

Configures a IReplicationGroupBacklog

Since:

8.0

Author:

eitany

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	BacklogConfig.LimitReachedPolicy Specifies the way to act when the configured limit of the backlog is reached

Field Summary

Fields

Modifier and Type	Field and Description
protected static BacklogConfig.LimitReachedPolicy	DEFAULT_BACKLOG_REACHED_POLICY
static long	UNLIMITED

Constructor Summary

Constructors

Constructor and Description
BacklogConfig()

Method Summary

Modifier and Type	Method and Description
BacklogConfig	clone()
BacklogMemberLimitationConfig	getBacklogMemberLimitation(String memberName)
BacklogWeightPolicy	getBackLogWeightPolicy()
long	getLimit(String memberLookupName)
long	getLimitDuringSynchronization(String memberName)
BacklogConfig.LimitReachedPolicy	getLimitDuringSynchronizationReachedPolicy(String memberLookupName)
int	getLimitedMemoryCapacity()
BacklogConfig.LimitReachedPolicy	getLimitReachedPolicy(String memberLookupName)
String	getMirrorMemberName()
RedoLogCompaction	getRedoLogCompaction()
SwapBacklogConfig	getSwapBacklogConfig()
boolean	isLimited(String memberLookupName)
boolean	isLimitedDuringSynchronization(String memberName)
boolean	isLimitedMemoryCapacity()
protected void	overrideWithOther(BacklogConfig other)
void	removeMemberConfig(String memberName)
void	setBackLogWeightPolicy(String policy)
void	setLimit(String memberLookupName, long limit, BacklogConfig.LimitReachedPolicy limitReachedPolicy)
void	setLimitDuringSynchronization(String memberName, long limit, BacklogConfig.LimitReachedPolicy limitReachedPolicy)
void	setLimitedMemoryCapacity(int limitedMemoryCapacity)
void	setMemberBacklogLimitation(String memberName, BacklogMemberLimitationConfig memberLimitationConfig)
void	setMirrorMemberName(String _mirrorMemberName)
void	setRedoLogCompaction(RedoLogCompaction _redoLogCompaction)
void	setSwapBacklogConfig(SwapBacklogConfig swapBacklogConfig)
void	setUnlimited(String memberLookupName)
void	setUnlimitedDuringSynchronization(String memberName)
void	setUnlimitedMemoryCapacity()
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

UNLIMITED

public static final long UNLIMITED

See Also:

Constant Field Values

DEFAULT_BACKLOG_REACHED_POLICY

protected static final BacklogConfig.LimitReachedPolicy DEFAULT_BACKLOG_REACHED_POLICY

Constructor Detail

BacklogConfig

public BacklogConfig()

Method Detail

setLimit

public void setLimit(String memberLookupName,
                     long limit,
                     BacklogConfig.LimitReachedPolicy limitReachedPolicy)

getLimit

public long getLimit(String memberLookupName)

setUnlimited

public void setUnlimited(String memberLookupName)

isLimited

public boolean isLimited(String memberLookupName)

getLimitReachedPolicy

public BacklogConfig.LimitReachedPolicy getLimitReachedPolicy(String memberLookupName)

setUnlimitedDuringSynchronization

public void setUnlimitedDuringSynchronization(String memberName)

isLimitedDuringSynchronization

public boolean isLimitedDuringSynchronization(String memberName)

setLimitDuringSynchronization

public void setLimitDuringSynchronization(String memberName,
                                          long limit,
                                          BacklogConfig.LimitReachedPolicy limitReachedPolicy)

getLimitDuringSynchronization

public long getLimitDuringSynchronization(String memberName)

getLimitDuringSynchronizationReachedPolicy

public BacklogConfig.LimitReachedPolicy getLimitDuringSynchronizationReachedPolicy(String memberLookupName)

setMemberBacklogLimitation

public void setMemberBacklogLimitation(String memberName,
                                       BacklogMemberLimitationConfig memberLimitationConfig)

getBacklogMemberLimitation

public BacklogMemberLimitationConfig getBacklogMemberLimitation(String memberName)

isLimitedMemoryCapacity

public boolean isLimitedMemoryCapacity()

setLimitedMemoryCapacity

public void setLimitedMemoryCapacity(int limitedMemoryCapacity)

getLimitedMemoryCapacity

public int getLimitedMemoryCapacity()

setUnlimitedMemoryCapacity

public void setUnlimitedMemoryCapacity()

setSwapBacklogConfig

public void setSwapBacklogConfig(SwapBacklogConfig swapBacklogConfig)

getMirrorMemberName

public String getMirrorMemberName()

setMirrorMemberName

public void setMirrorMemberName(String _mirrorMemberName)

getRedoLogCompaction

public RedoLogCompaction getRedoLogCompaction()

setRedoLogCompaction

public void setRedoLogCompaction(RedoLogCompaction _redoLogCompaction)

getSwapBacklogConfig

public SwapBacklogConfig getSwapBacklogConfig()

clone

public BacklogConfig clone()

Overrides:

clone in class Object

removeMemberConfig

public void removeMemberConfig(String memberName)

overrideWithOther

protected void overrideWithOther(BacklogConfig other)

toString

public String toString()

Overrides:

toString in class Object

getBackLogWeightPolicy

public BacklogWeightPolicy getBackLogWeightPolicy()

setBackLogWeightPolicy

public void setBackLogWeightPolicy(String policy)