egommerce/go-api-pkg
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

register fix

Browse Source
This commit is contained in:
Piotr Biernat 2022-12-01 22:55:42 +01:00
parent a4f4b6e059
commit ad4368cdf8
1 changed files with 11 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
consul/discovery.go
View File

@ -36,6 +36,11 @@ func NewService(serverAddr, appID, appName, ip, domain string, appPort int) (*Se
if err != nil { if err != nil {
return nil, err return nil, err
} }
kv := client.KV()
obj := new(consul.KVPair)
obj.Key = "traefik/http/services/" + s.Name + "/loadBalancer/servers/0/url"
obj.Value = []byte(s.GetFullAddr())
kv.Put(obj, nil)
s.ConsulAgent = client.Agent() s.ConsulAgent = client.Agent()
return s, nil return s, nil
@ -72,6 +77,7 @@ func (s *Service) Register() error {
if err := s.ConsulAgent.ServiceRegister(def); err != nil { if err := s.ConsulAgent.ServiceRegister(def); err != nil {
return err return err
} }
// s.ConsulAgent.
go s.UpdateTTL(def) go s.UpdateTTL(def)
return nil return nil
@ -120,8 +126,11 @@ func (s *Service) check() (bool, error) {
func (s *Service) getMetadata() map[string]string { func (s *Service) getMetadata() map[string]string {
m := map[string]string{} m := map[string]string{}
key := fmt.Sprintf(`traefik/http/services/%s/loadBalancer/servers/0/url`, s.Name) m[`traefik_dwa`] = "a"
m[key] = s.GetFullAddr()
// key := "traefik%2Ftest"
// key := "traefik/http/services/" + s.Name + "/loadBalancer/servers/0/url"
// m[key] = s.GetFullAddr()
fmt.Printf("netadata: %v", m) fmt.Printf("netadata: %v", m)