maxappendentries

api.go

@@ -499,7 +499,7 @@ func NewRaft(conf *Config, fsm FSM, logs LogStore, stable StableStore, snaps Sna
 	// Create Raft struct.
 	r := &Raft{
 		protocolVersion:       protocolVersion,
-		applyCh:               make(chan *logFuture, conf.ApplyChSize),
+		applyCh:               make(chan *logFuture, conf.MaxAppendEntries),
 		conf:                  *conf,
 		fsm:                   fsm,
 		fsmMutateCh:           make(chan interface{}, 128),

config.go

@@ -145,9 +145,6 @@ type Config struct {
 	// staggering, may be delayed as much as 2x this value.
 	CommitTimeout time.Duration
 
-	// ApplyChSize will buffer applyCh with the configured size.
-	ApplyChSize int
-
 	// MaxAppendEntries controls the maximum number of append entries
 	// to send at once. We want to strike a balance between efficiency
 	// and avoiding waste if the follower is going to reject because of