|
49 | 49 | querierInterceptor func(*http.Request, UserContext) (*http.Request, error) |
50 | 50 | querierGlobalCacheTag uint64 |
51 | 51 | querierDisableCache bool |
| 52 | + querierHTTPClient *http.Client |
52 | 53 | ) |
53 | 54 |
|
54 | 55 | func SetQuerierApiVersionForTests(version string) { |
@@ -113,8 +114,7 @@ func (q *Querier) GetQuerierAPIVersion(userContextIn ...UserContext) (string, er |
113 | 114 | req.Header = headers |
114 | 115 | } |
115 | 116 |
|
116 | | - client := &http.Client{} |
117 | | - resp, err := client.Do(req) |
| 117 | + resp, err := querierHTTPClient.Do(req) |
118 | 118 | return resp, nil, err |
119 | 119 | }, len(QuerierHosts), nil) |
120 | 120 |
|
@@ -162,6 +162,8 @@ func initQuerier(hosts []QuerierHost, APIKey string, interceptor func(*http.Requ |
162 | 162 | querierInterceptor = interceptor |
163 | 163 | querierGlobalCacheTag = GetCurrTimeInMS() |
164 | 164 | querierDisableCache = disableCache |
| 165 | + |
| 166 | + querierHTTPClient = &http.Client{} |
165 | 167 | } |
166 | 168 | } |
167 | 169 |
|
@@ -205,8 +207,7 @@ func (q *Querier) SendPostRequest(path string, data map[string]interface{}, user |
205 | 207 | } |
206 | 208 | } |
207 | 209 |
|
208 | | - client := &http.Client{} |
209 | | - resp, err := client.Do(req) |
| 210 | + resp, err := querierHTTPClient.Do(req) |
210 | 211 | return resp, nil, err |
211 | 212 | }, len(QuerierHosts), nil) |
212 | 213 | return resp, err |
@@ -256,8 +257,7 @@ func (q *Querier) SendDeleteRequest(path string, data map[string]interface{}, pa |
256 | 257 | } |
257 | 258 | } |
258 | 259 |
|
259 | | - client := &http.Client{} |
260 | | - resp, err := client.Do(req) |
| 260 | + resp, err := querierHTTPClient.Do(req) |
261 | 261 | return resp, nil, err |
262 | 262 | }, len(QuerierHosts), nil) |
263 | 263 | return resp, err |
@@ -360,8 +360,7 @@ func (q *Querier) SendGetRequest(path string, params map[string]string, userCont |
360 | 360 | } |
361 | 361 | } |
362 | 362 |
|
363 | | - client := &http.Client{} |
364 | | - response, err := client.Do(req) |
| 363 | + response, err := querierHTTPClient.Do(req) |
365 | 364 | if err != nil { |
366 | 365 | return nil, nil, err |
367 | 366 | } |
@@ -435,8 +434,7 @@ func (q *Querier) SendGetRequestWithResponseHeaders(path string, params map[stri |
435 | 434 | } |
436 | 435 | } |
437 | 436 |
|
438 | | - client := &http.Client{} |
439 | | - resp, err := client.Do(req) |
| 437 | + resp, err := querierHTTPClient.Do(req) |
440 | 438 | return resp, nil, err |
441 | 439 | }, len(QuerierHosts), nil) |
442 | 440 | } |
@@ -478,8 +476,7 @@ func (q *Querier) SendPutRequest(path string, data map[string]interface{}, userC |
478 | 476 | } |
479 | 477 | } |
480 | 478 |
|
481 | | - client := &http.Client{} |
482 | | - resp, err := client.Do(req) |
| 479 | + resp, err := querierHTTPClient.Do(req) |
483 | 480 | return resp, nil, err |
484 | 481 | }, len(QuerierHosts), nil) |
485 | 482 | return resp, err |
|
0 commit comments