Compare commits
9 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| dad915f2ec | |||
| 54e4006d0d | |||
| 9cb590bf7a | |||
| 70c41dab96 | |||
| 99ac0a83c6 | |||
| 30c45b4503 | |||
| 49f552bf68 | |||
| 6f875cbb94 | |||
| f9331deec1 |
@@ -61,16 +61,22 @@ func (s *Service) GetID() string {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (s *Service) GetFullAddr() 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 {
|
func (s *Service) Register() error {
|
||||||
def := &consul.AgentServiceRegistration{
|
def := &consul.AgentServiceRegistration{
|
||||||
ID: s.GetID(),
|
ID: s.GetID(),
|
||||||
|
Kind: consul.ServiceKindConnectProxy,
|
||||||
Name: s.Name,
|
Name: s.Name,
|
||||||
Address: s.Address,
|
Address: s.Address,
|
||||||
Port: s.port,
|
Port: s.port,
|
||||||
Tags: s.getTags(),
|
Tags: s.getTags(),
|
||||||
|
Connect: &consul.AgentServiceConnect{
|
||||||
|
// SidecarService: &consul.AgentServiceRegistration{
|
||||||
|
// Port: s.port,
|
||||||
|
// },
|
||||||
|
},
|
||||||
Check: &consul.AgentServiceCheck{
|
Check: &consul.AgentServiceCheck{
|
||||||
TTL: s.ttl.String(),
|
TTL: s.ttl.String(),
|
||||||
Status: "passing",
|
Status: "passing",
|
||||||
@@ -138,6 +144,7 @@ func (s *Service) healthCheck() (bool, error) {
|
|||||||
fmt.Printf("Sending HEALTH CHECK request to: %s\n", healthUrl)
|
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 {
|
||||||
|
fmt.Printf("Sending HEALTH CHECK request error: %v\n", err)
|
||||||
return false
|
return false
|
||||||
}
|
}
|
||||||
defer resp.Body.Close()
|
defer resp.Body.Close()
|
||||||
|
|||||||
Reference in New Issue
Block a user