Enforce ElectionTimeout >= HeartbeatTimeout

raft.go

@@ -129,6 +129,11 @@ func NewRaft(conf *Config, fsm FSM, logs LogStore, stable StableStore, snaps Sna
 		conf.LogOutput = os.Stderr
 	}
 
+	// Ensure the ElectionTimeout is not less than the HeartbeatTimeout
+	if conf.ElectionTimeout < conf.HeartbeatTimeout {
+		return nil, fmt.Errorf("ElectionTimeout must be equal or greater than HeartbeatTimeout")
+	}
+
 	// Try to restore the current term
 	currentTerm, err := stable.GetUint64(keyCurrentTerm)
 	if err != nil && err.Error() != "not found" {

raft_test.go

@@ -557,6 +557,7 @@ func TestRaft_ApplyConcurrent(t *testing.T) {
 	// Make the cluster
 	conf := inmemConfig()
 	conf.HeartbeatTimeout = 100 * time.Millisecond
+	conf.ElectionTimeout = 100 * time.Millisecond
 	c := MakeCluster(3, t, conf)
 	defer c.Close()
 
@@ -600,6 +601,7 @@ func TestRaft_ApplyConcurrent_Timeout(t *testing.T) {
 	// Make the cluster
 	conf := inmemConfig()
 	conf.HeartbeatTimeout = 100 * time.Millisecond
+	conf.ElectionTimeout = 100 * time.Millisecond
 	c := MakeCluster(1, t, conf)
 	defer c.Close()