Compare commits

...

2 Commits

Author SHA1 Message Date
1018e24060 Updated TTL param 2025-04-26 12:05:55 +02:00
ebef6e138d Consul update 2024-12-24 18:15:48 +01:00

View File

@@ -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)