From c8b2f7ce33fa290c13ce35eea27ab7dd59ddd252 Mon Sep 17 00:00:00 2001 From: Sean Chittenden Date: Wed, 1 Jun 2016 23:26:54 -0700 Subject: [PATCH] Flesh out the comment re: the client.rpcproxy.Run() task. Requested by: Alex --- client/client.go | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) diff --git a/client/client.go b/client/client.go index 9a2cbc671..67c8002b7 100644 --- a/client/client.go +++ b/client/client.go @@ -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