Compare commits

...

2 Commits

Author SHA1 Message Date
65dbbc16df register fix 2022-12-01 23:37:43 +01:00
e5c95b0476 register fix 2022-12-01 23:24:25 +01:00

View File

@@ -5,7 +5,6 @@ import (
"log"
"net/http"
"strconv"
"strings"
"time"
consul "github.com/hashicorp/consul/api"
@@ -14,8 +13,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 +22,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 = strings.Replace(appName, "-", "", -1)
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
}
@@ -58,14 +57,14 @@ 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: s.Name,
Address: s.IP,
Address: s.Address,
Port: s.Port,
Tags: s.getTags(),
Meta: s.getMetadata(),
@@ -146,7 +145,7 @@ func (s *Service) getTags() []string {
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,