func (t *transport) AppendEntries(id raft.ServerID, target raft.ServerAddress, args *raft.AppendEntriesRequest, resp *raft.AppendEntriesResponse) error {
	ae := appendEntries{
		source:      t.node,
		target:      target,
		firstIndex:  firstIndex(args),
		lastIndex:   lastIndex(args),
		commitIndex: args.LeaderCommitIndex,
	}
	if len(t.ae) < cap(t.ae) {
		t.ae = append(t.ae, ae)
	}
	return t.sendRPC(string(target), args, resp)
}
func (t *transport) AppendEntries(id raft.ServerID, target raft.ServerAddress, args *raft.AppendEntriesRequest, resp *raft.AppendEntriesResponse) error {
	ae := appendEntries{
		source:      t.node,
		target:      target,
		firstIndex:  firstIndex(args),
		lastIndex:   lastIndex(args),
		commitIndex: args.LeaderCommitIndex,
	}
	if len(t.ae) < cap(t.ae) {
		t.ae = append(t.ae, ae)
	}
	return t.sendRPC(string(target), args, resp)
}
func ( t * transport ) AppendEntries ( id raft . ServerID , target raft . ServerAddress , args * raft . AppendEntriesRequest , resp * raft . AppendEntriesResponse ) error { ae := appendEntries { source : t . node , target : target , firstIndex : firstIndex ( args ) , lastIndex : lastIndex ( args ) , commitIndex : args . LeaderCommitIndex , } if len ( t . ae ) < cap ( t . ae ) { t . ae = append ( t . ae , ae ) } return t . sendRPC ( string ( target ) , args , resp ) }
// AppendEntries sends the appropriate RPC to the target node.
AppendEntries sends the appropriate RPC to the target node .