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

Consul refactor

Browse Source
This commit is contained in:
Piotr Biernat 2023-06-29 14:13:23 +02:00
parent 6dd11c6441
commit 5451899e48
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
consul/discovery.go
View File

@ -19,8 +19,8 @@ type Service struct {
port int port int
ttl time.Duration ttl time.Duration
agent *consul.Agent agent *consul.Agent
connect *consul.Connect
kv *consul.KV kv *consul.KV
catalog *consul.Catalog
} }
var ErrServiceUnavailable = fmt.Errorf("Service is unavailable") var ErrServiceUnavailable = fmt.Errorf("Service is unavailable")
@ -40,8 +40,8 @@ func NewService(servAddr, id, name, hostname, domain, pathPrefix string, appPort
return nil, err return nil, err
} }
s.agent = client.Agent() s.agent = client.Agent()
s.connect = client.Connect()
s.kv = client.KV() s.kv = client.KV()
s.catalog = client.Catalog()
return s, nil return s, nil
} }
@ -103,12 +103,12 @@ func (s *Service) Unregister() error {
return s.agent.ServiceDeregister(s.GetID()) return s.agent.ServiceDeregister(s.GetID())
} }
func (s *Service) KV() *consul.KV { func (s *Service) Connect() *consul.Connect {
return s.kv return s.connect
} }
func (s *Service) Catalog() *consul.Catalog { func (s *Service) KV() *consul.KV {
return s.catalog return s.kv
} }
func (s *Service) healthCheck() (bool, error) { func (s *Service) healthCheck() (bool, error) {