Compare commits
3 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 672a350f31 | |||
| c01098b672 | |||
| 566cbbd31b |
@@ -91,5 +91,5 @@ func (c *HttpClient) getApiUrl(api string) string {
|
|||||||
apiAddr = api // default api run on 80 int port
|
apiAddr = api // default api run on 80 int port
|
||||||
}
|
}
|
||||||
|
|
||||||
return "http://" + apiAddr
|
return "https://" + apiAddr
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -21,7 +21,7 @@ type Service struct {
|
|||||||
ttl time.Duration
|
ttl time.Duration
|
||||||
client *consul.Client
|
client *consul.Client
|
||||||
agent *consul.Agent
|
agent *consul.Agent
|
||||||
connect *consul.Connect
|
connect *connect.Service
|
||||||
kv *consul.KV
|
kv *consul.KV
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -61,7 +61,7 @@ func (s *Service) GetID() string {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (s *Service) GetFullAddr() string {
|
func (s *Service) GetFullAddr() string {
|
||||||
return fmt.Sprintf("http://%s:%d/", s.Address, s.port)
|
return fmt.Sprintf("https://%s:%d/?name=%s", s.Address, s.port, s.Name)
|
||||||
}
|
}
|
||||||
|
|
||||||
func (s *Service) Register() error {
|
func (s *Service) Register() error {
|
||||||
@@ -107,7 +107,10 @@ func (s *Service) Unregister() error {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (s *Service) Connect() (*connect.Service, error) {
|
func (s *Service) Connect() (*connect.Service, error) {
|
||||||
return connect.NewService(s.Name, s.client)
|
svc, err := connect.NewService(s.Name, s.client)
|
||||||
|
s.connect = svc
|
||||||
|
|
||||||
|
return svc, err
|
||||||
}
|
}
|
||||||
|
|
||||||
func (s *Service) KV() *consul.KV {
|
func (s *Service) KV() *consul.KV {
|
||||||
|
|||||||
Reference in New Issue
Block a user