(invoke *invoke, invokeErr *messages.InvokeResponse_Error)
| 102 | } |
| 103 | |
| 104 | func reportFailure(invoke *invoke, invokeErr *messages.InvokeResponse_Error) error { |
| 105 | errorPayload := safeMarshal(invokeErr) |
| 106 | log.Printf("%s", errorPayload) |
| 107 | |
| 108 | causeForXRay, err := json.Marshal(makeXRayError(invokeErr)) |
| 109 | if err != nil { |
| 110 | return fmt.Errorf("unexpected error occurred when serializing the function error cause for X-Ray: %v", err) |
| 111 | } |
| 112 | |
| 113 | if err := invoke.failure(bytes.NewReader(errorPayload), contentTypeJSON, causeForXRay); err != nil { |
| 114 | return fmt.Errorf("unexpected error occurred when sending the function error to the API: %v", err) |
| 115 | } |
| 116 | return nil |
| 117 | } |
| 118 | |
| 119 | func callBytesHandlerFunc(ctx context.Context, payload []byte, handler handlerFunc) (response io.Reader, invokeErr *messages.InvokeResponse_Error) { |
| 120 | defer func() { |
no test coverage detected
searching dependent graphs…