(requestID string)
| 146 | } |
| 147 | |
| 148 | func (h *AsyncMessageHandler) getPayload(requestID string) (io.ReadCloser, error) { |
| 149 | key := async.PayloadPath(h.storagePath, requestID) |
| 150 | output, err := h.aws.S3().GetObject( |
| 151 | &s3.GetObjectInput{ |
| 152 | Key: aws.String(key), |
| 153 | Bucket: aws.String(h.config.Bucket), |
| 154 | }, |
| 155 | ) |
| 156 | if err != nil { |
| 157 | return nil, errors.WithStack(err) |
| 158 | } |
| 159 | return output.Body, nil |
| 160 | } |
| 161 | |
| 162 | func (h *AsyncMessageHandler) deletePayload(requestID string) { |
| 163 | key := async.PayloadPath(h.storagePath, requestID) |
no test coverage detected