6 "github.com/aws/aws-sdk-go/aws/awserr"
7 "github.com/aws/aws-sdk-go/aws/request"
10 // RequestFailure provides additional S3 specific metadata for the request
12 type RequestFailure struct {
18 // NewRequestFailure returns a request failure error decordated with S3
20 func NewRequestFailure(err awserr.RequestFailure, hostID string) *RequestFailure {
21 return &RequestFailure{RequestFailure: err, hostID: hostID}
24 func (r RequestFailure) Error() string {
25 extra := fmt.Sprintf("status code: %d, request id: %s, host id: %s",
26 r.StatusCode(), r.RequestID(), r.hostID)
27 return awserr.SprintError(r.Code(), r.Message(), extra, r.OrigErr())
29 func (r RequestFailure) String() string {
33 // HostID returns the HostID request response value.
34 func (r RequestFailure) HostID() string {
38 // RequestFailureWrapperHandler returns a handler to rap an
39 // awserr.RequestFailure with the S3 request ID 2 from the response.
40 func RequestFailureWrapperHandler() request.NamedHandler {
41 return request.NamedHandler{
42 Name: "awssdk.s3.errorHandler",
43 Fn: func(req *request.Request) {
44 reqErr, ok := req.Error.(awserr.RequestFailure)
45 if !ok || reqErr == nil {
49 hostID := req.HTTPResponse.Header.Get("X-Amz-Id-2")
54 req.Error = NewRequestFailure(reqErr, hostID)