Compare commits
7 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 30c45b4503 | |||
| 49f552bf68 | |||
| 6f875cbb94 | |||
| f9331deec1 | |||
| c29bb94c3d | |||
| 8d884eebda | |||
| 2f022919ff |
@@ -61,7 +61,7 @@ func (s *Service) GetID() string {
|
||||
}
|
||||
|
||||
func (s *Service) GetFullAddr() string {
|
||||
return fmt.Sprintf("https://%s:%d/", s.domain, s.port)
|
||||
return fmt.Sprintf("http://%s:%d/", s.domain, s.port)
|
||||
}
|
||||
|
||||
func (s *Service) Register() error {
|
||||
@@ -71,6 +71,7 @@ func (s *Service) Register() error {
|
||||
Address: s.Address,
|
||||
Port: s.port,
|
||||
Tags: s.getTags(),
|
||||
Connect: &consul.AgentServiceConnect{SidecarService: &consul.AgentServiceRegistration{}},
|
||||
Check: &consul.AgentServiceCheck{
|
||||
TTL: s.ttl.String(),
|
||||
Status: "passing",
|
||||
@@ -108,7 +109,10 @@ func (s *Service) Unregister() error {
|
||||
}
|
||||
|
||||
func (s *Service) Connect() (*connect.Service, error) {
|
||||
svc, err := connect.NewService(s.Name, s.client)
|
||||
// srvName := s.Name
|
||||
srvName := s.Name
|
||||
fmt.Printf("CONNECT SERVER: %s\n", srvName)
|
||||
svc, err := connect.NewService(srvName, s.client)
|
||||
s.connect = svc
|
||||
cnf := svc.ServerTLSConfig()
|
||||
for k, c := range cnf.Certificates {
|
||||
@@ -135,6 +139,7 @@ func (s *Service) healthCheck() (bool, error) {
|
||||
fmt.Printf("Sending HEALTH CHECK request to: %s\n", healthUrl)
|
||||
resp, err := client.Do(req)
|
||||
if err != nil {
|
||||
fmt.Printf("Sending HEALTH CHECK request error: %v\n", err)
|
||||
return false
|
||||
}
|
||||
defer resp.Body.Close()
|
||||
|
||||
Reference in New Issue
Block a user