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

nomad: track local peers

Browse Source
This commit is contained in:
Armon Dadgar
2015-06-07 11:32:01 -07:00
parent c8df91e8c9
commit 2dceb5345b
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
nomad/server.go
View File

@@ -65,8 +65,9 @@ type Server struct {
// peers is used to track the known Nomad servers. This is
// used for region forwarding and clustering.
peers map[string][]*serverParts
peerLock sync.RWMutex
peers map[string][]*serverParts
localPeers map[string]*serverParts
peerLock sync.RWMutex
// serf is the Serf cluster containing only Nomad
// servers. This is used for multi-region federation
@@ -114,6 +115,7 @@ func NewServer(config *Config) (*Server, error) {
logger: logger,
rpcServer: rpc.NewServer(),
peers: make(map[string][]*serverParts),
localPeers: make(map[string]*serverParts),
reconcileCh: make(chan serf.Member, 32),
eventCh: make(chan serf.Event, 256),
shutdownCh: make(chan struct{}),