Compare commits

...

19 Commits

Author SHA1 Message Date
03ec5a0a5a consul ttl fix 2022-12-02 19:02:21 +01:00
fb251e3648 consul ttl fix 2022-12-02 18:55:40 +01:00
32a89d9747 consul ttl fix 2022-12-02 18:48:12 +01:00
3b6acdc195 consul ttl fix 2022-12-02 17:42:39 +01:00
128e3db0b6 register fix 2022-12-02 16:18:00 +01:00
e0a18538d4 register fix 2022-12-02 14:24:27 +01:00
d99436d2d6 register fix 2022-12-02 14:21:33 +01:00
bc27da0be3 register fix 2022-12-02 03:28:38 +01:00
b8cfbf6b99 register fix 2022-12-02 03:22:36 +01:00
2204f6116b register fix 2022-12-02 01:20:55 +01:00
65dbbc16df register fix 2022-12-01 23:37:43 +01:00
e5c95b0476 register fix 2022-12-01 23:24:25 +01:00
34ace207a7 register fix 2022-12-01 23:12:53 +01:00
ad4368cdf8 register fix 2022-12-01 22:55:42 +01:00
a4f4b6e059 register fix 2022-12-01 20:28:23 +01:00
5bf58aad16 register fix 2022-12-01 20:26:22 +01:00
ba6bd4137c register fix 2022-12-01 20:19:28 +01:00
48a7e968d1 register fix 2022-12-01 19:54:59 +01:00
6c46a0e6a4 register fix 2022-12-01 19:45:47 +01:00

View File

@@ -2,10 +2,8 @@ package consul
import (
"fmt"
"log"
"net/http"
"strconv"
"strings"
"time"
consul "github.com/hashicorp/consul/api"
@@ -14,8 +12,8 @@ import (
type Service struct {
AppID string
Name string
Domain string
Address string
IP string
Port int
TTL time.Duration
ConsulAgent *consul.Agent
@@ -23,16 +21,16 @@ type Service struct {
var ErrServiceUnavailable = fmt.Errorf("Service is unavailable")
func NewService(serverAddr, appID, appName, ip, domain string, appPort int) (*Service, error) {
func NewService(servAddr, id, name, hostname, domain string, appPort int) (*Service, error) {
s := new(Service)
s.AppID = appID
s.Name = appName
s.Address = domain
s.IP = ip
s.AppID = id
s.Name = name
s.Address = hostname
s.Domain = domain
s.Port = appPort
s.TTL = time.Second * 15
client, err := consul.NewClient(newClientConfig(serverAddr))
client, err := consul.NewClient(newClientConfig(servAddr))
if err != nil {
return nil, err
}
@@ -53,17 +51,16 @@ func (s *Service) GetID() string {
}
func (s *Service) GetFullAddr() string {
return fmt.Sprintf("http://%s:%d/", s.IP, s.Port)
return fmt.Sprintf("http://%s:%d/", s.Address, s.Port)
}
func (s *Service) Register() error {
def := &consul.AgentServiceRegistration{
ID: s.GetID(),
Name: strings.Replace(s.Name, "-", "_", -1),
Address: s.IP,
Name: s.Name,
Address: s.Address,
Port: s.Port,
Tags: s.getTags(),
Meta: s.getMetadata(),
Check: &consul.AgentServiceCheck{
TTL: s.TTL.String(),
},
@@ -72,7 +69,27 @@ func (s *Service) Register() error {
if err := s.ConsulAgent.ServiceRegister(def); err != nil {
return err
}
go s.UpdateTTL(def)
go func() { // startup register
ticker := time.NewTicker(time.Millisecond * 100)
for range ticker.C {
ok, _ := s.healthCheck()
if ok {
ticker.Stop()
}
}
}()
go func() { // TTL
interval := s.TTL - time.Second*2
ticker := time.NewTicker(interval)
for range ticker.C {
_, err := s.healthCheck()
if err != nil {
fmt.Printf("TTL Error: %v\n", err)
}
}
}()
return nil
}
@@ -80,67 +97,51 @@ func (s *Service) Unregister() error {
return s.ConsulAgent.ServiceDeregister(s.GetID())
}
func (s *Service) UpdateTTL(service *consul.AgentServiceRegistration) {
ticker := time.NewTicker(s.TTL / 2)
for range ticker.C {
ok, err := s.check()
if !ok {
if err := s.ConsulAgent.FailTTL("service:"+s.GetID(), err.Error()); err != nil {
log.Println(err)
}
} else {
if err := s.ConsulAgent.PassTTL("service:"+s.GetID(), "OK"); err != nil {
log.Println(err)
}
func (s *Service) healthCheck() (bool, error) {
alive := func() bool {
client := &http.Client{}
healthUrl := s.GetFullAddr() + "health"
req, err := http.NewRequest(http.MethodGet, healthUrl, nil)
if err != nil {
return false
}
}
}
req.Header.Set("User-Agent", "Health Check")
func (s *Service) check() (bool, error) {
client := &http.Client{}
healthUrl := fmt.Sprintf("http://%s/health", s.GetFullAddr())
req, err := http.NewRequest(http.MethodGet, healthUrl, nil)
if err != nil {
return false, ErrServiceUnavailable
}
req.Header.Set("User-Agent", "Health Check")
resp, err := client.Do(req)
if err != nil {
return false
}
defer resp.Body.Close()
resp, err := client.Do(req)
if err != nil {
return false, ErrServiceUnavailable
}
defer resp.Body.Close()
return resp.StatusCode == http.StatusOK
}()
if resp.StatusCode == http.StatusOK {
if alive {
if err := s.ConsulAgent.PassTTL("service:"+s.GetID(), "OK"); err != nil {
return false, err
}
return true, nil
}
if err := s.ConsulAgent.FailTTL("service:"+s.GetID(), ErrServiceUnavailable.Error()); err != nil {
return false, err
}
return false, ErrServiceUnavailable
}
func (s *Service) getMetadata() map[string]string {
m := map[string]string{}
m["traefik/http/services/"+s.Name+"/loadBalancer/servers/0/url"] = s.GetFullAddr()
return m
}
func (s *Service) getTags() []string {
// fullName := fmt.Sprintf("%s-%s", s.Name, s.AppID)
// bFullAddr := fmt.Sprintf("http://%s:%d/", s.IP, s.Port) // FIXME: declare one once - dont need to refresh....
tags := []string{
"traefik.enable=true",
"traefik.http.routers." + s.Name + ".rule=Host(`" + s.Address + "`)",
"traefik.http.routers." + s.Name + ".rule=Host(`" + s.Domain + "`)",
"traefik.http.routers." + s.Name + ".entryPoints=https",
"traefik.http.routers." + s.Name + ".tls=true",
"traefik.http.routers." + s.Name + ".service=" + s.Name,
"traefik.http.routers." + s.Name + ".middlewares=compress,requestid",
"traefik.http.services." + s.Name + ".loadbalancer.passhostheader=false",
"traefik.http.services." + s.Name + ".loadbalancer.server.scheme=http",
"traefik.http.services." + s.Name + ".loadbalancer.server.port=" + strconv.Itoa(s.Port),
"traefik.http.middlewares.compress.compress=true",
"traefik.http.middlewares.requestid.plugin.requestid.headerName=X-Request-ID",
// "traefik.http.services." + s.Name + ".loadbalancer.passhostheader=false",
// "traefik.http.services." + s.Name + ".loadbalancer.servers." + fullName + "=" + bFullAddr,
// "traefik.http.services." + s.Name + ".loadbalancer.servers." + fullName + ".url=" + bFullAddr,
// "traefik.http.services." + s.Name + ".loadbalancer.healthcheck.path=/health",