opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/ConfigParams.java

   1 /*
   2  * Copyright (c) 2014 Cisco Systems, Inc. and others.  All rights reserved.
   3  *
   4  * This program and the accompanying materials are made available under the
   5  * terms of the Eclipse Public License v1.0 which accompanies this distribution,
   6  * and is available at http://www.eclipse.org/legal/epl-v10.html
   7  */
   8 package org.opendaylight.controller.cluster.raft;
   9
  10 import org.eclipse.jdt.annotation.NonNull;
  11 import org.opendaylight.controller.cluster.raft.policy.RaftPolicy;
  12 import scala.concurrent.duration.FiniteDuration;
  13
  14 /**
  15  * Configuration Parameter interface for configuring the Raft consensus system
  16  *
  17  * <p>
  18  * Any component using this implementation might want to provide an implementation of
  19  * this interface to configure
  20  *
  21  * <p>
  22  * A default implementation will be used if none is provided.
  23  *
  24  * @author Kamal Rameshan
  25  */
  26 public interface ConfigParams {
  27     int MEGABYTE = 1048576;
  28
  29     /**
  30      * Returns the minimum number of entries to be present in the in-memory Raft log for a snapshot to be taken.
  31      *
  32      * @return the minimum number of entries.
  33      */
  34     long getSnapshotBatchCount();
  35
  36     /**
  37      * Returns the percentage of total memory used in the in-memory Raft log before a snapshot should be taken.
  38      *
  39      * @return the percentage.
  40      */
  41     int getSnapshotDataThresholdPercentage();
  42
  43     /**
  44      * Returns the interval at which a heart beat message should be sent to remote followers.
  45      *
  46      * @return the interval as a FiniteDuration.
  47      */
  48     FiniteDuration getHeartBeatInterval();
  49
  50     /**
  51      * Returns the interval after which a new election should be triggered if no leader is available.
  52      *
  53      * @return the interval as a FiniteDuration.
  54      */
  55     FiniteDuration getElectionTimeOutInterval();
  56
  57     /**
  58      * Returns the maximum election time variance. The election is scheduled using both the election timeout
  59      * and variance.
  60      *
  61      * @return the election time variance.
  62      */
  63     int getElectionTimeVariance();
  64
  65     /**
  66      * Returns the maximum size (in bytes) for the snapshot chunk sent from a Leader.
  67      *
  68      * @return the maximum size (in bytes).
  69      */
  70     int getSnapshotChunkSize();
  71
  72     /**
  73      * Returns the maximum number of journal log entries to batch on recovery before applying.
  74      *
  75      * @return the maximum number of journal log entries.
  76      */
  77     int getJournalRecoveryLogBatchSize();
  78
  79     /**
  80      * Returns the interval in which the leader needs to check if its isolated.
  81      *
  82      * @return the interval in ms.
  83      */
  84     long getIsolatedCheckIntervalInMillis();
  85
  86
  87     /**
  88      * Returns the multiplication factor to be used to determine the shard election timeout. The election timeout
  89      * is determined by multiplying the election timeout factor with the heart beat duration.
  90      *
  91      * @return the election timeout factor.
  92      */
  93     long getElectionTimeoutFactor();
  94
  95
  96     /**
  97      * Returns the RaftPolicy used to determine certain Raft behaviors.
  98      *
  99      * @return an instance of RaftPolicy, if set, or an instance of the DefaultRaftPolicy.
 100      */
 101     @NonNull RaftPolicy getRaftPolicy();
 102
 103     /**
 104      * Returns the PeerAddressResolver.
 105      *
 106      * @return the PeerAddressResolver instance.
 107      */
 108     @NonNull PeerAddressResolver getPeerAddressResolver();
 109
 110     /**
 111      * Returns the custom RaftPolicy class name.
 112      *
 113      * @return the RaftPolicy class name or null if none set.
 114      */
 115     String getCustomRaftPolicyImplementationClass();
 116
 117     /**
 118      * Returns the directory in which to create temp files.
 119      *
 120      * @return the directory in which to create temp files.
 121      */
 122     @NonNull String getTempFileDirectory();
 123
 124     /**
 125      * Returns the threshold in terms of number of bytes when streaming data before it should switch from storing in
 126      * memory to buffering to a file.
 127      *
 128      * @return the threshold in terms of number of bytes.
 129      */
 130     int getFileBackedStreamingThreshold();
 131
 132     /**
 133      * Returns the threshold in terms of number journal entries that we can lag behind a leader until we raise a
 134      * 'not synced' transition.
 135      *
 136      * @return the threshold in terms of number of journal entries.
 137      */
 138     long getSyncIndexThreshold();
 139 }