Compare commits
3 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 90e832af61 | |||
| 3d8c706835 | |||
| a37f6209ff |
@@ -87,15 +87,15 @@ func (s *Service) Register() error {
|
||||
}
|
||||
}(s)
|
||||
|
||||
// go func(s *Service) { // TTL
|
||||
// interval := s.ttl - time.Second*2 // 2 seconds overhead
|
||||
// ticker := time.NewTicker(interval)
|
||||
// for range ticker.C {
|
||||
// if _, err := s.healthCheck(); err != nil {
|
||||
// fmt.Printf("TTL Error #: %v\n", err)
|
||||
// }
|
||||
// }
|
||||
// }(s)
|
||||
go func(s *Service) { // TTL
|
||||
interval := s.ttl - time.Second*2 // 2 seconds overhead
|
||||
ticker := time.NewTicker(interval)
|
||||
for range ticker.C {
|
||||
if _, err := s.healthCheck(); err != nil {
|
||||
fmt.Printf("TTL Error #: %v\n", err)
|
||||
}
|
||||
}
|
||||
}(s)
|
||||
|
||||
return nil
|
||||
}
|
||||
@@ -117,16 +117,19 @@ func (s *Service) healthCheck() (bool, error) {
|
||||
healthUrl := s.GetFullAddr() + "health"
|
||||
req, err := http.NewRequest(http.MethodGet, healthUrl, nil)
|
||||
if err != nil {
|
||||
fmt.Printf("CreateRequest error: %v\n", err)
|
||||
return false
|
||||
}
|
||||
req.Header.Set("User-Agent", "service/internal")
|
||||
|
||||
resp, err := client.Do(req)
|
||||
if err != nil {
|
||||
fmt.Printf("SendRequest error: %v\n", err)
|
||||
return false
|
||||
}
|
||||
defer resp.Body.Close()
|
||||
|
||||
fmt.Printf("ResponseCODE: %v\n", resp.StatusCode)
|
||||
return resp.StatusCode == http.StatusOK
|
||||
}()
|
||||
|
||||
|
||||
Reference in New Issue
Block a user