Compare commits

...

2 Commits

Author SHA1 Message Date
3b73091cfb consul fixes 2023-07-29 15:11:22 +02:00
c8beab76f1 consul fixes 2023-07-29 14:57:36 +02:00

View File

@@ -9,7 +9,6 @@ import (
"git.pbiernat.dev/egommerce/go-api-pkg/config" "git.pbiernat.dev/egommerce/go-api-pkg/config"
consul "github.com/hashicorp/consul/api" consul "github.com/hashicorp/consul/api"
"github.com/hashicorp/consul/connect" "github.com/hashicorp/consul/connect"
"github.com/hashicorp/go-hclog"
) )
type Service struct { type Service struct {
@@ -62,7 +61,12 @@ func (s *Service) GetID() string {
} }
func (s *Service) GetFullAddr() string { func (s *Service) GetFullAddr() string {
return fmt.Sprintf("https://%s:%d/", s.domain, s.port) isTLS := s.port == 443
proto := "http"
if isTLS {
proto = "https"
}
return fmt.Sprintf("%s://%s:%d/", proto, s.domain, s.port)
} }
func (s *Service) Register() error { func (s *Service) Register() error {
@@ -73,9 +77,7 @@ func (s *Service) Register() error {
Address: s.Address, Address: s.Address,
Port: s.port, Port: s.port,
Tags: s.getTags(), Tags: s.getTags(),
Connect: &consul.AgentServiceConnect{ // Connect: &consul.AgentServiceConnect{Native: true},
Native: true,
},
// Proxy: &consul.AgentServiceConnectProxyConfig{ // Proxy: &consul.AgentServiceConnectProxyConfig{
// DestinationServiceName: s.Name, // DestinationServiceName: s.Name,
// }, // },
@@ -118,11 +120,11 @@ func (s *Service) RegisterHealthChecks() {
} }
func (s *Service) Connect() (*connect.Service, error) { func (s *Service) Connect() (*connect.Service, error) {
l := hclog.New(&hclog.LoggerOptions{ // l := hclog.New(&hclog.LoggerOptions{
Name: "consul-registry", // Name: "consul-registry",
Level: hclog.Trace, // Level: hclog.Trace,
}) // })
svc, err := connect.NewServiceWithLogger(s.Name, s.client, l) svc, err := connect.NewService(s.Name, s.client)
s.connect = svc s.connect = svc
cnf := svc.ServerTLSConfig() cnf := svc.ServerTLSConfig()
fmt.Printf("CONNECT SERVER:: %s CONFIG:: %v\n", s.Name, cnf) fmt.Printf("CONNECT SERVER:: %s CONFIG:: %v\n", s.Name, cnf)