public interface ConfigParams
Any component using this implementation might want to provide an implementation of this interface to configure
A default implementation will be used if none is provided.
Modifier and Type | Field and Description |
---|---|
static int |
MEGABYTE |
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.
|
static final int MEGABYTE
long getSnapshotBatchCount()
int getSnapshotDataThresholdPercentage()
scala.concurrent.duration.FiniteDuration getHeartBeatInterval()
scala.concurrent.duration.FiniteDuration getElectionTimeOutInterval()
int getElectionTimeVariance()
int getSnapshotChunkSize()
int getJournalRecoveryLogBatchSize()
long getIsolatedCheckIntervalInMillis()
long getElectionTimeoutFactor()
@Nonnull RaftPolicy getRaftPolicy()
@Nonnull PeerAddressResolver getPeerAddressResolver()
String getCustomRaftPolicyImplementationClass()
@Nonnull String getTempFileDirectory()
int getFileBackedStreamingThreshold()
long getSyncIndexThreshold()
Copyright © 2019 OpenDaylight. All rights reserved.