( ctx context.Context, method string, path string, query url.Values, requestBody any, credentials agentidentity.Credentials, responseBody any, )
| 5352 | } |
| 5353 | |
| 5354 | func (c *unixSocketClient) doAgentJSON( |
| 5355 | ctx context.Context, |
| 5356 | method string, |
| 5357 | path string, |
| 5358 | query url.Values, |
| 5359 | requestBody any, |
| 5360 | credentials agentidentity.Credentials, |
| 5361 | responseBody any, |
| 5362 | ) error { |
| 5363 | response, err := c.doRequestWithCredentials(ctx, method, path, query, requestBody, "", credentials) |
| 5364 | if err != nil { |
| 5365 | return err |
| 5366 | } |
| 5367 | defer func() { |
| 5368 | _ = response.Body.Close() |
| 5369 | }() |
| 5370 | |
| 5371 | return c.decodeJSONResponse(ctx, method, path, response, responseBody) |
| 5372 | } |
| 5373 | |
| 5374 | func (c *unixSocketClient) decodeJSONResponse( |
| 5375 | _ context.Context, |
no test coverage detected