( ctx context.Context, method string, path string, query url.Values, requestBody any, lastEventID string, credentials agentidentity.Credentials, )
| 5500 | } |
| 5501 | |
| 5502 | func (c *unixSocketClient) doRequestWithCredentials( |
| 5503 | ctx context.Context, |
| 5504 | method string, |
| 5505 | path string, |
| 5506 | query url.Values, |
| 5507 | requestBody any, |
| 5508 | lastEventID string, |
| 5509 | credentials agentidentity.Credentials, |
| 5510 | ) (*http.Response, error) { |
| 5511 | return c.doRequestWithCredentialsAndClient( |
| 5512 | ctx, |
| 5513 | method, |
| 5514 | path, |
| 5515 | query, |
| 5516 | requestBody, |
| 5517 | lastEventID, |
| 5518 | credentials, |
| 5519 | c.httpClient, |
| 5520 | ) |
| 5521 | } |
| 5522 | |
| 5523 | // doRequestWithCredentialsAndClient lets SSE streams opt out of the JSON request timeout. |
| 5524 | func (c *unixSocketClient) doRequestWithCredentialsAndClient( |
no test coverage detected