ben/gocast
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

check for error

Browse Source
This commit is contained in:
Naveen Achyuta
2022-09-01 13:59:24 -07:00
parent e1825b4581
commit 8a36bb153a
1 changed files with 9 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
controller/consul.go
View File

@@ -85,6 +85,9 @@ func (c *ConsulMon) queryServices() ([]*App, error) {
}
addr := c.addr + fmt.Sprintf("%s/%s?%s", nodeURL, c.node, stale)
req, err := getHTTPReq(http.MethodGet, addr, c.token)
if err != nil {
return apps, err
}
resp, err := c.client.Do(req)
if err != nil {
return apps, err
@@ -143,6 +146,9 @@ func (c *ConsulMon) healthCheckLocal(service string) (bool, error) {
params.Add("filter", "enable_gocast in ServiceTags")
addr := c.addr + fmt.Sprintf("%s?%s", localHealthCheckurl, params.Encode())
req, err := getHTTPReq(http.MethodGet, addr, c.token)
if err != nil {
return false, err
}
resp, err := c.client.Do(req)
if err != nil {
glog.V(2).Infof("Error getting %s with %s", addr, err)
@@ -172,6 +178,9 @@ func (c *ConsulMon) healthCheckLocal(service string) (bool, error) {
func (c *ConsulMon) healthCheckRemote(service string) (bool, error) {
addr := c.addr + fmt.Sprintf("%s/%s", remoteHealthCheckurl, service)
req, err := getHTTPReq(http.MethodGet, addr, c.token)
if err != nil {
return false, err
}
resp, err := c.client.Do(req)
if err != nil {
glog.V(2).Infof("Error getting %s with %s", addr, err)