X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-akka-raft%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fraft%2FConfigParams.java;h=8351374d60fe0e73bb5ca2fbfa2ea01cbd5a3f52;hp=78a1335d58a2ed7cacf78572425be7beb20274ca;hb=7cb260aeb0738104e3bee8a086de9e2e5f77b7e0;hpb=7fcaf37fb411e26859ad761b329af1df9dd46c13 diff --git a/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/ConfigParams.java b/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/ConfigParams.java index 78a1335d58..8351374d60 100644 --- a/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/ConfigParams.java +++ b/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/ConfigParams.java @@ -7,81 +7,151 @@ */ package org.opendaylight.controller.cluster.raft; +import org.eclipse.jdt.annotation.NonNull; +import org.opendaylight.controller.cluster.raft.policy.RaftPolicy; import scala.concurrent.duration.FiniteDuration; /** - * Configuration Parameter interface for configuring the Raft consensus system - *

- * 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. + * Configuration Parameter interface for configuring the Raft consensus system. 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. * * @author Kamal Rameshan */ public interface ConfigParams { + int MEGABYTE = 1048576; + /** - * The minimum number of entries to be present in the in-memory Raft log - * for a snapshot to be taken + * Returns the minimum number of entries to be present in the in-memory Raft log for a snapshot to be taken. * - * @return long + * @return the minimum number of entries. */ long getSnapshotBatchCount(); /** - * The percentage of total memory in the in-memory Raft log before a snapshot - * is to be taken + * Returns the percentage of total memory used in the in-memory Raft log before a snapshot should be taken. + * Disabled when direct threshold is enabled. * - * @return int + * @return the percentage. */ int getSnapshotDataThresholdPercentage(); /** - * The interval at which a heart beat message will be sent to the remote - * RaftActor + * Returns the max size of memory used in the in-memory Raft log before a snapshot should be taken. 0 means that + * direct threshold is disabled and percentage is used instead. * - * @return FiniteDuration + * @return maximum journal size (in MiB). */ - FiniteDuration getHeartBeatInterval(); + int getSnapshotDataThreshold(); /** - * The interval in which a new election would get triggered if no leader is found + * Returns the interval(in seconds) after which a snapshot should be taken during recovery. Negative value means + * do not take snapshots. * - * Normally its set to atleast twice the heart beat interval + * @return the interval of recovery snapshot in seconds + */ + int getRecoverySnapshotIntervalSeconds(); + + /** + * Returns the interval at which a heart beat message should be sent to remote followers. + * + * @return the interval as a FiniteDuration. + */ + FiniteDuration getHeartBeatInterval(); + + /** + * Returns the interval after which a new election should be triggered if no leader is available. * - * @return FiniteDuration + * @return the interval as a FiniteDuration. */ FiniteDuration getElectionTimeOutInterval(); /** - * The maximum election time variance. The election is scheduled using both - * the Election Timeout and Variance + * Returns the number by which a candidate should divide the election timeout it has calculated. This serves + * to speed up retries when elections result in a stalemate. * - * @return int + * @return the interval as a FiniteDuration. + */ + long getCandidateElectionTimeoutDivisor(); + + /** + * Returns the maximum election time variance. The election is scheduled using both the election timeout + * and variance. + * + * @return the election time variance. */ int getElectionTimeVariance(); /** - * The size (in bytes) of the snapshot chunk sent from Leader + * Returns the maximum size (in bytes) for the snapshot chunk sent from a Leader. + * + * @return the maximum size (in bytes). */ int getSnapshotChunkSize(); /** - * The number of journal log entries to batch on recovery before applying. + * Returns the maximum number of journal log entries to batch on recovery before applying. + * + * @return the maximum number of journal log entries. */ int getJournalRecoveryLogBatchSize(); /** - * The interval in which the leader needs to check itself if its isolated - * @return FiniteDuration + * Returns the interval in which the leader needs to check if its isolated. + * + * @return the interval in ms. */ - FiniteDuration getIsolatedCheckInterval(); - + long getIsolatedCheckIntervalInMillis(); /** - * The multiplication factor to be used to determine shard election timeout. The election timeout - * is determined by multiplying the election timeout factor with the heartbeat duration. + * Returns the multiplication factor to be used to determine the shard election timeout. The election timeout + * is determined by multiplying the election timeout factor with the heart beat duration. + * + * @return the election timeout factor. */ long getElectionTimeoutFactor(); + /** + * Returns the RaftPolicy used to determine certain Raft behaviors. + * + * @return an instance of RaftPolicy, if set, or an instance of the DefaultRaftPolicy. + */ + @NonNull RaftPolicy getRaftPolicy(); + + /** + * Returns the PeerAddressResolver. + * + * @return the PeerAddressResolver instance. + */ + @NonNull PeerAddressResolver getPeerAddressResolver(); + + /** + * Returns the custom RaftPolicy class name. + * + * @return the RaftPolicy class name or null if none set. + */ + String getCustomRaftPolicyImplementationClass(); + + /** + * Returns the directory in which to create temp files. + * + * @return the directory in which to create temp files. + */ + @NonNull String getTempFileDirectory(); + + /** + * 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. + * + * @return the threshold in terms of number of bytes. + */ + int getFileBackedStreamingThreshold(); + + /** + * Returns the threshold in terms of number journal entries that we can lag behind a leader until we raise a + * 'not synced' transition. + * + * @return the threshold in terms of number of journal entries. + */ + long getSyncIndexThreshold(); }