|
|
|
@@ -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/", s.Address, s.port)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
func (s *Service) Register() error {
|
|
|
|
func (s *Service) Register() error {
|
|
|
|
@@ -120,13 +120,14 @@ func (s *Service) KV() *consul.KV {
|
|
|
|
func (s *Service) healthCheck() (bool, error) {
|
|
|
|
func (s *Service) healthCheck() (bool, error) {
|
|
|
|
alive := func() bool {
|
|
|
|
alive := func() bool {
|
|
|
|
client := &http.Client{}
|
|
|
|
client := &http.Client{}
|
|
|
|
healthUrl := s.GetFullAddr() + "health"
|
|
|
|
healthUrl := fmt.Sprintf("%s%s?name=%s", s.GetFullAddr(), "health", s.Name)
|
|
|
|
req, err := http.NewRequest(http.MethodGet, healthUrl, nil)
|
|
|
|
req, err := http.NewRequest(http.MethodGet, healthUrl, nil)
|
|
|
|
if err != nil {
|
|
|
|
if err != nil {
|
|
|
|
return false
|
|
|
|
return false
|
|
|
|
}
|
|
|
|
}
|
|
|
|
req.Header.Set("User-Agent", "service/internal")
|
|
|
|
req.Header.Set("User-Agent", "service/internal")
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
fmt.Printf("Sending HEALTH CHECK request to: %s\n", healthUrl)
|
|
|
|
resp, err := client.Do(req)
|
|
|
|
resp, err := client.Do(req)
|
|
|
|
if err != nil {
|
|
|
|
if err != nil {
|
|
|
|
return false
|
|
|
|
return false
|
|
|
|
|