Compare commits
2 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| effc7a6039 | |||
| 457142d8ad |
@@ -80,19 +80,17 @@ func (s *Service) Register() error {
|
||||
go func(s *Service) { // startup register
|
||||
ticker := time.NewTicker(time.Millisecond * 100)
|
||||
for range ticker.C {
|
||||
ok, _ := s.healthCheck()
|
||||
if ok {
|
||||
if ok, _ := s.healthCheck(); ok {
|
||||
ticker.Stop()
|
||||
}
|
||||
}
|
||||
}(s)
|
||||
|
||||
go func(s *Service) { // TTL
|
||||
interval := s.ttl - time.Second*2
|
||||
interval := s.ttl - time.Second*2 // 2 seconds overhead
|
||||
ticker := time.NewTicker(interval)
|
||||
for range ticker.C {
|
||||
_, err := s.healthCheck()
|
||||
if err != nil {
|
||||
if _, err := s.healthCheck(); err != nil {
|
||||
fmt.Printf("TTL Error: %v\n", err)
|
||||
}
|
||||
}
|
||||
|
||||
@@ -10,7 +10,7 @@ func ParseAddr(addr string) (string, int, error) {
|
||||
fHost := p[0]
|
||||
fPort, err := strconv.Atoi(p[1])
|
||||
if err != nil {
|
||||
return nil, nil, err
|
||||
return "", 0, err
|
||||
}
|
||||
|
||||
return fHost, fPort, nil
|
||||
|
||||
Reference in New Issue
Block a user