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

Clean up some docs and comments to be more accurate

Browse Source
This commit is contained in:
Sean Chittenden
2016-06-01 02:41:04 -07:00
parent 445386bb3f
commit 41904f262f
1 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
client/client.go
View File

@@ -200,7 +200,7 @@ func NewClient(cfg *config.Config, consulSyncer *consul.Syncer) (*Client, error)
// Setup the Consul syncer
if err := c.setupConsulSyncer(); err != nil {
return nil, fmt.Errorf("failed to create Consul syncer: %v")
return nil, fmt.Errorf("failed to create client Consul syncer: %v")
}
// Register and then start heartbeating to the servers.
@@ -1213,12 +1213,13 @@ func (c *Client) addAlloc(alloc *structs.Allocation) error {
return nil
}
// setupConsulSyncer creates a consul.Syncer
// setupConsulSyncer creates Client-mode consul.Syncer callbacks that are
// executed periodically.
func (c *Client) setupConsulSyncer() error {
// The bootstrapFn callback handler is used to periodically poll
// Consul to look up the Nomad Servers in Consul. In the event the
// heartbeat deadline has been exceeded and this Agent is orphaned
// from its cluster, periodically poll Consul to reattach this Agent
// heartbeat deadline has been exceeded and this Client is orphaned
// from its servers, periodically poll Consul to reattach this Client
// to its cluster and automatically recover from a detached state.
bootstrapFn := func() {
now := time.Now()