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

Flesh out the comment re: the client.rpcproxy.Run() task.

Browse Source 
Requested by: Alex
This commit is contained in:
Sean Chittenden
2016-06-01 23:26:54 -07:00
parent 9de963497b
commit c8b2f7ce33
1 changed files with 8 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
client/client.go
View File

@@ -218,7 +218,14 @@ func NewClient(cfg *config.Config, consulSyncer *consul.Syncer) (*Client, error)
// Start collecting stats
go c.collectHostStats()
// Start maintenance task for servers
// Start the RpcProxy maintenance task. This task periodically
// shuffles the list of Nomad Server Endpoints this Client will use
// when communicating with Nomad Servers via RPC. This is done in
// order to prevent server fixation in stable Nomad clusters. This
// task actively populates the active list of Nomad Server Endpoints
// from information from the Nomad Client heartbeats. If a heartbeat
// times out and there are no Nomad servers available, this data is
// populated by periodically polling Consul, if available.
go c.rpcProxy.Run()
return c, nil