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

Not logging if consul is unavailable

Browse Source
This commit is contained in:
Diptanu Choudhury
2016-04-02 14:48:10 -07:00
parent 6ebf0e9a07
commit 7ca2d28baa
1 changed files with 14 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
client/consul/sync.go
View File

@@ -19,7 +19,8 @@ import (
// ConsulService allows syncing of services and checks with Consul
type ConsulService struct {
client *consul.Client
client *consul.Client
availble bool
task *structs.Task
allocID string
@@ -349,7 +350,12 @@ func (c *ConsulService) PeriodicSync() {
select {
case <-sync.C:
if err := c.performSync(); err != nil {
c.logger.Printf("[DEBUG] consul: error in syncing task %q: %v", c.task.Name, err)
if c.availble {
c.logger.Printf("[DEBUG] consul: error in syncing task %q: %v", c.task.Name, err)
}
c.availble = false
} else {
c.availble = true
}
case <-c.shutdownCh:
sync.Stop()
@@ -438,6 +444,11 @@ func (c *ConsulService) runCheck(check Check) {
state = consul.HealthCritical
}
if err := c.client.Agent().UpdateTTL(check.ID(), output, state); err != nil {
c.logger.Printf("[DEBUG] error updating ttl check for check %q: %v", check.ID(), err)
if c.availble {
c.logger.Printf("[DEBUG] error updating ttl check for check %q: %v", check.ID(), err)
c.availble = false
} else {
c.availble = true
}
}
}