kemko/nomad
1
0
Fork 0
mirror of https://github.com/kemko/nomad.git synced 2026-01-06 10:25:42 +03:00
Code Issues Packages Projects Releases Wiki Activity

Fold RaftPeers() into its only call site now

Browse Source
This commit is contained in:
Sean Chittenden
2016-06-10 01:20:18 -04:00
parent b57f7c97c2
commit 709b6bd787
1 changed files with 1 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
nomad/server.go
View File

@@ -690,16 +690,6 @@ func (s *Server) RPC(method string, args interface{}, reply interface{}) error {
return codec.err
}
// RaftPeers returns the current list of Raft peers
func (s *Server) RaftPeers() ([]string, error) {
peers, err := s.raftPeers.Peers()
if err != nil {
s.logger.Printf("[DEBUG] server: error getting raft peers: %v", err)
return nil, err
}
return peers, nil
}
// Stats is used to return statistics for debugging and insight
// for various sub-systems
func (s *Server) Stats() map[string]map[string]string {
@@ -718,7 +708,7 @@ func (s *Server) Stats() map[string]map[string]string {
"serf": s.serf.Stats(),
"runtime": RuntimeStats(),
}
if peers, err := s.RaftPeers(); err == nil {
if peers, err := s.raftPeers.Peers(); err == nil {
stats["raft"]["raft_peers"] = strings.Join(peers, ",")
} else {
s.logger.Printf("[DEBUG] server: error getting raft peers: %v", err)