Compare commits
2 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 1018e24060 | |||
| ebef6e138d |
@@ -2,7 +2,6 @@ package consul
|
||||
|
||||
import (
|
||||
"fmt"
|
||||
"log"
|
||||
"net/http"
|
||||
"strconv"
|
||||
"time"
|
||||
@@ -46,7 +45,6 @@ func NewService(servAddr, id, name, useDomainOverIp, addr, domain, pathPrefix st
|
||||
if useDomainOverIp == "true" { // FIXME types...
|
||||
s.Address = domain
|
||||
}
|
||||
log.Printf("Init consul with server addr: %s", s.Address)
|
||||
|
||||
client, err := consul.NewClient(newClientConfig(servAddr))
|
||||
if err != nil {
|
||||
@@ -62,7 +60,6 @@ func NewService(servAddr, id, name, useDomainOverIp, addr, domain, pathPrefix st
|
||||
|
||||
func newClientConfig(serverAddr string) *consul.Config {
|
||||
conf := consul.DefaultConfig()
|
||||
log.Printf("Setting consul server addr: %s", serverAddr)
|
||||
conf.Address = serverAddr
|
||||
|
||||
return conf
|
||||
@@ -130,7 +127,7 @@ func (s *Service) RegisterHealthChecks() {
|
||||
}()
|
||||
|
||||
go func() { // TTL
|
||||
t := time.NewTicker(s.ttl)
|
||||
t := time.NewTicker(time.Second * 5)
|
||||
for range t.C {
|
||||
if _, err := s.healthCheck(); err != nil {
|
||||
// fmt.Printf("HealthCheck endpoint not available (%s)#: %v\n", s.GetFullAddr(), err)
|
||||
|
||||
Reference in New Issue
Block a user