Compare commits
2 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| a37f6209ff | |||
| fc88125fe4 |
@@ -87,15 +87,15 @@ func (s *Service) Register() error {
|
|||||||
}
|
}
|
||||||
}(s)
|
}(s)
|
||||||
|
|
||||||
// go func(s *Service) { // TTL
|
go func(s *Service) { // TTL
|
||||||
// interval := s.ttl - time.Second*2 // 2 seconds overhead
|
interval := s.ttl - time.Second*2 // 2 seconds overhead
|
||||||
// ticker := time.NewTicker(interval)
|
ticker := time.NewTicker(interval)
|
||||||
// for range ticker.C {
|
for range ticker.C {
|
||||||
// if _, err := s.healthCheck(); err != nil {
|
if _, err := s.healthCheck(); err != nil {
|
||||||
// fmt.Printf("TTL Error #: %v\n", err)
|
fmt.Printf("TTL Error #: %v\n", err)
|
||||||
// }
|
}
|
||||||
// }
|
}
|
||||||
// }(s)
|
}(s)
|
||||||
|
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
@@ -119,7 +119,7 @@ func (s *Service) healthCheck() (bool, error) {
|
|||||||
if err != nil {
|
if err != nil {
|
||||||
return false
|
return false
|
||||||
}
|
}
|
||||||
req.Header.Set("User-Agent", "Health Check")
|
req.Header.Set("User-Agent", "service/internal")
|
||||||
|
|
||||||
resp, err := client.Do(req)
|
resp, err := client.Do(req)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
@@ -132,6 +132,7 @@ func (s *Service) healthCheck() (bool, error) {
|
|||||||
|
|
||||||
if alive {
|
if alive {
|
||||||
if err := s.agent.PassTTL("service:"+s.GetID(), "OK"); err != nil {
|
if err := s.agent.PassTTL("service:"+s.GetID(), "OK"); err != nil {
|
||||||
|
fmt.Printf("Failed to pass TTL: %v", err)
|
||||||
return false, err
|
return false, err
|
||||||
}
|
}
|
||||||
return true, nil
|
return true, nil
|
||||||
|
|||||||
Reference in New Issue
Block a user