Compare commits
7 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 91eeb6f275 | |||
| dc34531c4f | |||
| 12a241de81 | |||
| ef2567e0b6 | |||
| bb410b3158 | |||
| 7bbc717786 | |||
| a1870e07b5 |
@@ -61,7 +61,7 @@ func (s *Service) GetID() string {
|
||||
}
|
||||
|
||||
func (s *Service) GetFullAddr() string {
|
||||
return fmt.Sprintf("https://%s:%d/", s.Address, s.port)
|
||||
return fmt.Sprintf("https://%s:%d/", s.domain, s.port)
|
||||
}
|
||||
|
||||
func (s *Service) Register() error {
|
||||
@@ -73,6 +73,7 @@ func (s *Service) Register() error {
|
||||
Tags: s.getTags(),
|
||||
Check: &consul.AgentServiceCheck{
|
||||
TTL: s.ttl.String(),
|
||||
Status: "passing",
|
||||
DeregisterCriticalServiceAfter: "10s",
|
||||
},
|
||||
}
|
||||
@@ -109,6 +110,10 @@ func (s *Service) Unregister() error {
|
||||
func (s *Service) Connect() (*connect.Service, error) {
|
||||
svc, err := connect.NewService(s.Name, s.client)
|
||||
s.connect = svc
|
||||
cnf := svc.ServerTLSConfig()
|
||||
for k, c := range cnf.Certificates {
|
||||
fmt.Printf("CONNECT CERT %d: %v", k, c)
|
||||
}
|
||||
|
||||
return svc, err
|
||||
}
|
||||
@@ -127,13 +132,17 @@ func (s *Service) healthCheck() (bool, error) {
|
||||
}
|
||||
req.Header.Set("User-Agent", "service/internal")
|
||||
|
||||
fmt.Printf("Sending HEALTH CHECK request to: %s", healthUrl)
|
||||
fmt.Printf("Sending HEALTH CHECK request to: %s\n", healthUrl)
|
||||
resp, err := client.Do(req)
|
||||
if err != nil {
|
||||
return false
|
||||
}
|
||||
defer resp.Body.Close()
|
||||
|
||||
var body []byte
|
||||
resp.Body.Read(body)
|
||||
fmt.Printf("HEALTH CHECK response to: %v -- %v\n", resp, body)
|
||||
|
||||
return resp.StatusCode == http.StatusOK
|
||||
}()
|
||||
|
||||
|
||||
Reference in New Issue
Block a user