etcd: unknowNode -> unknownPeer

etcd/peer.go

@@ -2,7 +2,6 @@ package etcd
 
 import (
 	"bytes"
-	"errors"
 	"fmt"
 	"log"
 	"net/http"
@@ -20,10 +19,6 @@ const (
 	stopped
 )
 
-var (
-	errUnknownNode = errors.New("unknown node")
-)
-
 type peer struct {
 	url      string
 	queue    chan []byte

etcd/peer_hub.go

@@ -1,6 +1,7 @@
 package etcd
 
 import (
+	"errors"
 	"fmt"
 	"io/ioutil"
 	"net/http"
@@ -9,6 +10,10 @@ import (
 	"sync"
 )
 
+var (
+	errUnknownPeer = errors.New("unknown peer")
+)
+
 type peerGetter interface {
 	peer(id int64) (*peer, error)
 }
@@ -70,7 +75,7 @@ func (h *peerHub) send(nodeId int64, data []byte) error {
 	if p == nil {
 		err := h.fetch(nodeId)
 		if err != nil {
-			return err
+			return errUnknownPeer
 		}
 	}