( ctx context.Context, id string, action string, requestBody TaskExecutionRequest, )
| 5319 | } |
| 5320 | |
| 5321 | func (c *unixSocketClient) taskExecutionAction( |
| 5322 | ctx context.Context, |
| 5323 | id string, |
| 5324 | action string, |
| 5325 | requestBody TaskExecutionRequest, |
| 5326 | ) (TaskExecutionRecord, error) { |
| 5327 | var response contract.TaskExecutionResponse |
| 5328 | path := "/api/tasks/" + url.PathEscape(id) + "/" + strings.TrimSpace(action) |
| 5329 | if err := c.doJSON(ctx, http.MethodPost, path, nil, requestBody, &response); err != nil { |
| 5330 | return TaskExecutionRecord{}, err |
| 5331 | } |
| 5332 | return response, nil |
| 5333 | } |
| 5334 | |
| 5335 | func (c *unixSocketClient) doJSON( |
| 5336 | ctx context.Context, |
no test coverage detected