(requestID string, result interface{})
| 211 | } |
| 212 | |
| 213 | func (h *AsyncMessageHandler) uploadResult(requestID string, result interface{}) error { |
| 214 | key := async.ResultPath(h.storagePath, requestID) |
| 215 | return h.aws.UploadJSONToS3(result, h.config.Bucket, key) |
| 216 | } |
| 217 | |
| 218 | func (h *AsyncMessageHandler) getHeaders(requestID string) (http.Header, error) { |
| 219 | key := async.HeadersPath(h.storagePath, requestID) |
no test coverage detected