Compare commits
2 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 37fa05402e | |||
| 615281ae9a |
@@ -99,17 +99,17 @@ func (s *Service) Register() error {
|
||||
return nil
|
||||
}
|
||||
func (s *Service) Unregister() error {
|
||||
// s.client.Catalog().Deregister(&consul.CatalogDeregistration{
|
||||
// Address: s.Address,
|
||||
// ServiceID: s.GetID(),
|
||||
// }, nil)
|
||||
s.client.Catalog().Deregister(&consul.CatalogDeregistration{
|
||||
Address: s.Address,
|
||||
ServiceID: s.GetID(),
|
||||
}, nil)
|
||||
|
||||
return s.agent.ServiceDeregister(s.GetID())
|
||||
}
|
||||
|
||||
func (s *Service) RegisterHealthChecks() {
|
||||
go func() { // startup register
|
||||
ticker := time.NewTicker(time.Second * 1)
|
||||
ticker := time.NewTicker(time.Second)
|
||||
for range ticker.C {
|
||||
if ok, _ := s.healthCheck(); ok {
|
||||
ticker.Stop()
|
||||
@@ -118,11 +118,11 @@ func (s *Service) RegisterHealthChecks() {
|
||||
}()
|
||||
|
||||
go func() { // TTL
|
||||
interval := s.ttl - (time.Second * 2) // 2 seconds overhead
|
||||
ticker := time.NewTicker(interval)
|
||||
ticker := time.NewTicker(s.ttl)
|
||||
for range ticker.C {
|
||||
if _, err := s.healthCheck(); err != nil {
|
||||
fmt.Printf("HealthCheck endpoint not available (%s)#: %v\n", s.GetFullAddr(), err)
|
||||
ticker.Stop()
|
||||
}
|
||||
}
|
||||
}()
|
||||
|
||||
Reference in New Issue
Block a user