status-im
/
consul
mirror of https://github.com/status-im/consul.git
2
0
Fork 0
Code Issues Projects Releases Wiki Activity

ServerAddressProvider interface also returns an error now

This commit is contained in:
Preetha Appan 2017-08-29 14:12:32 -05:00
parent c68fce89b5
commit 830aca958a
1 changed files with 4 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
agent/consul/server.go
View File

@ -1049,16 +1049,15 @@ func (s *Server) GetWANCoordinate() (*coordinate.Coordinate, error) {
return s.serfWAN.GetCoordinate()
}
func (s *Server) ServerAddr(id raft.ServerID) raft.ServerAddress {
func (s *Server) ServerAddr(id raft.ServerID) (raft.ServerAddress, error) {
if string(id) == string(s.config.NodeID) {
return raft.ServerAddress(s.config.RPCAddr.String())
return raft.ServerAddress(s.config.RPCAddr.String()), nil
}
addr, err := s.router.GetServerAddressByID(s.config.Datacenter, string(id))
if err != nil {
s.logger.Println("[WARN] Unable to find address for raft server id %v", id)
return raft.ServerAddress("")
return "", err
}
return raft.ServerAddress(addr)
return raft.ServerAddress(addr), nil
}
// Atomically sets a readiness state flag when leadership is obtained, to indicate that server is past its barrier write