MINOR: service_discovery: add mode handling for consul api requests

rmaticevic · rmaticevic · commit c5ce6139d795 · 2023-09-21T11:25:12.000+02:00
diff --git a/discovery/consul_service_discovery_instance.go b/discovery/consul_service_discovery_instance.go
@@ -325,8 +325,12 @@ func (c *consulInstance) queryHealthService(se string, params *queryParams) ([]*
 }
 
 func (c *consulInstance) doConsulQuery(method string, path string, params *queryParams, resp interface{}) (*queryMetadata, error) {
+	mode := "http://"
+	if c.params.Mode != nil {
+		mode = fmt.Sprintf("%s://", *c.params.Mode)
+	}
 	fullPath, err := url.JoinPath(
-		"http://",
+		mode,
 		net.JoinHostPort(*c.params.Address, strconv.FormatInt(*c.params.Port, 10)),
 		path,
 	)

Original file line number	Diff line number	Diff line change
`@@ -325,8 +325,12 @@ func (c consulInstance) queryHealthService(se string, params queryParams) ([]*`
`325`	`325`	`}`
`326`	`326`
`327`	`327`	`func (c consulInstance) doConsulQuery(method string, path string, params queryParams, resp interface{}) (*queryMetadata, error) {`
	`328`	`+ mode := "http://"`
	`329`	`+ if c.params.Mode != nil {`
	`330`	`+ mode = fmt.Sprintf("%s://", *c.params.Mode)`
	`331`	`+ }`
`328`	`332`	`fullPath, err := url.JoinPath(`
`329`		`- "http://",`
	`333`	`+ mode,`
`330`	`334`	`net.JoinHostPort(c.params.Address, strconv.FormatInt(c.params.Port, 10)),`
`331`	`335`	`path,`
`332`	`336`	`)`