Influxdata
/
influxdb
mirror of https://github.com/influxdata/influxdb.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Prefix remaining Raft paths with 'raft'

pull/1249/head
Philip O'Toole 2014-12-19 16:31:40 -05:00
parent e31c58d580
commit b124a46fe2
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
raft/transport.go
View File

@ -134,7 +134,7 @@ func (t *HTTPTransport) Leave(uri *url.URL, id uint64) error {
func (t *HTTPTransport) Heartbeat(uri *url.URL, term, commitIndex, leaderID uint64) (uint64, uint64, error) {
// Construct URL.
u := *uri
u.Path = path.Join(u.Path, "heartbeat")
u.Path = path.Join(u.Path, "raft/heartbeat")
// Set URL parameters.
v := &url.Values{}
@ -176,7 +176,7 @@ func (t *HTTPTransport) Heartbeat(uri *url.URL, term, commitIndex, leaderID uint
func (t *HTTPTransport) ReadFrom(uri *url.URL, id, term, index uint64) (io.ReadCloser, error) {
// Construct URL.
u := *uri
u.Path = path.Join(u.Path, "stream")
u.Path = path.Join(u.Path, "raft/stream")
// Set URL parameters.
v := &url.Values{}
@ -204,7 +204,7 @@ func (t *HTTPTransport) ReadFrom(uri *url.URL, id, term, index uint64) (io.ReadC
func (t *HTTPTransport) RequestVote(uri *url.URL, term, candidateID, lastLogIndex, lastLogTerm uint64) (uint64, error) {
// Construct URL.
u := *uri
u.Path = path.Join(u.Path, "vote")
u.Path = path.Join(u.Path, "raft/vote")
// Set URL parameters.
v := &url.Values{}