public class DefaultConfigParamsImpl extends Object implements ConfigParams
Modifier and Type | Field and Description |
---|---|
static scala.concurrent.duration.FiniteDuration |
HEART_BEAT_INTERVAL
The interval at which a heart beat message will be sent to the remote
RaftActor.
|
MEGABYTE
Constructor and Description |
---|
DefaultConfigParamsImpl() |
Modifier and Type | Method and Description |
---|---|
String |
getCustomRaftPolicyImplementationClass()
Returns the custom RaftPolicy class name.
|
long |
getElectionTimeoutFactor()
Returns the multiplication factor to be used to determine the shard election timeout.
|
scala.concurrent.duration.FiniteDuration |
getElectionTimeOutInterval()
Returns the interval after which a new election should be triggered if no leader is available.
|
int |
getElectionTimeVariance()
Returns the maximum election time variance.
|
int |
getFileBackedStreamingThreshold()
Returns the threshold in terms of number of bytes when streaming data before it should switch from storing in
memory to buffering to a file.
|
scala.concurrent.duration.FiniteDuration |
getHeartBeatInterval()
Returns the interval at which a heart beat message should be sent to remote followers.
|
long |
getIsolatedCheckIntervalInMillis()
Returns the interval in which the leader needs to check if its isolated.
|
int |
getJournalRecoveryLogBatchSize()
Returns the maximum number of journal log entries to batch on recovery before applying.
|
PeerAddressResolver |
getPeerAddressResolver()
Returns the PeerAddressResolver.
|
RaftPolicy |
getRaftPolicy()
Returns the RaftPolicy used to determine certain Raft behaviors.
|
long |
getSnapshotBatchCount()
Returns the minimum number of entries to be present in the in-memory Raft log for a snapshot to be taken.
|
int |
getSnapshotChunkSize()
Returns the maximum size (in bytes) for the snapshot chunk sent from a Leader.
|
int |
getSnapshotDataThresholdPercentage()
Returns the percentage of total memory used in the in-memory Raft log before a snapshot should be taken.
|
long |
getSyncIndexThreshold()
Returns the threshold in terms of number journal entries that we can lag behind a leader until we raise a
'not synced' transition.
|
String |
getTempFileDirectory()
Returns the directory in which to create temp files.
|
void |
setCustomRaftPolicyImplementationClass(String customRaftPolicyImplementationClass) |
void |
setElectionTimeoutFactor(long electionTimeoutFactor) |
void |
setFileBackedStreamingThreshold(int fileBackedStreamingThreshold) |
void |
setHeartBeatInterval(scala.concurrent.duration.FiniteDuration heartBeatInterval) |
void |
setIsolatedLeaderCheckInterval(scala.concurrent.duration.FiniteDuration isolatedLeaderCheckInterval) |
void |
setJournalRecoveryLogBatchSize(int journalRecoveryLogBatchSize) |
void |
setPeerAddressResolver(PeerAddressResolver peerAddressResolver) |
void |
setSnapshotBatchCount(long snapshotBatchCount) |
void |
setSnapshotChunkSize(int snapshotChunkSize) |
void |
setSnapshotDataThresholdPercentage(int snapshotDataThresholdPercentage) |
void |
setSyncIndexThreshold(long syncIndexThreshold) |
void |
setTempFileDirectory(String tempFileDirectory) |
public static final scala.concurrent.duration.FiniteDuration HEART_BEAT_INTERVAL
Since this is set to 100 milliseconds the Election timeout should be at least 200 milliseconds
public void setHeartBeatInterval(scala.concurrent.duration.FiniteDuration heartBeatInterval)
public void setSnapshotBatchCount(long snapshotBatchCount)
public void setSnapshotDataThresholdPercentage(int snapshotDataThresholdPercentage)
public void setSnapshotChunkSize(int snapshotChunkSize)
public void setJournalRecoveryLogBatchSize(int journalRecoveryLogBatchSize)
public void setIsolatedLeaderCheckInterval(scala.concurrent.duration.FiniteDuration isolatedLeaderCheckInterval)
public void setElectionTimeoutFactor(long electionTimeoutFactor)
public void setTempFileDirectory(String tempFileDirectory)
public void setFileBackedStreamingThreshold(int fileBackedStreamingThreshold)
public void setCustomRaftPolicyImplementationClass(String customRaftPolicyImplementationClass)
public String getCustomRaftPolicyImplementationClass()
ConfigParams
getCustomRaftPolicyImplementationClass
in interface ConfigParams
public long getSnapshotBatchCount()
ConfigParams
getSnapshotBatchCount
in interface ConfigParams
public int getSnapshotDataThresholdPercentage()
ConfigParams
getSnapshotDataThresholdPercentage
in interface ConfigParams
public scala.concurrent.duration.FiniteDuration getHeartBeatInterval()
ConfigParams
getHeartBeatInterval
in interface ConfigParams
public scala.concurrent.duration.FiniteDuration getElectionTimeOutInterval()
ConfigParams
getElectionTimeOutInterval
in interface ConfigParams
public int getElectionTimeVariance()
ConfigParams
getElectionTimeVariance
in interface ConfigParams
public int getSnapshotChunkSize()
ConfigParams
getSnapshotChunkSize
in interface ConfigParams
public int getJournalRecoveryLogBatchSize()
ConfigParams
getJournalRecoveryLogBatchSize
in interface ConfigParams
public long getIsolatedCheckIntervalInMillis()
ConfigParams
getIsolatedCheckIntervalInMillis
in interface ConfigParams
public long getElectionTimeoutFactor()
ConfigParams
getElectionTimeoutFactor
in interface ConfigParams
public RaftPolicy getRaftPolicy()
ConfigParams
getRaftPolicy
in interface ConfigParams
public String getTempFileDirectory()
ConfigParams
getTempFileDirectory
in interface ConfigParams
public int getFileBackedStreamingThreshold()
ConfigParams
getFileBackedStreamingThreshold
in interface ConfigParams
public PeerAddressResolver getPeerAddressResolver()
ConfigParams
getPeerAddressResolver
in interface ConfigParams
public void setPeerAddressResolver(@Nonnull PeerAddressResolver peerAddressResolver)
public long getSyncIndexThreshold()
ConfigParams
getSyncIndexThreshold
in interface ConfigParams
public void setSyncIndexThreshold(long syncIndexThreshold)
Copyright © 2019 OpenDaylight. All rights reserved.