(reqInfo *RequestInfo, input *InvocationInput)
| 102 | } |
| 103 | |
| 104 | func (s *RuntimeClient) makeInvokeHTTPRequest(reqInfo *RequestInfo, input *InvocationInput) *InvokeHTTPRequest { |
| 105 | req, cancel := ConvertProxyRequestToHTTP(reqInfo) |
| 106 | invokeReq := &InvokeHTTPRequest{ |
| 107 | RequestID: input.RequestID, |
| 108 | Request: req, |
| 109 | FunctionTimeout: *input.Configuration.Timeout, |
| 110 | Logger: input.Logger, |
| 111 | CtxCancel: cancel, |
| 112 | } |
| 113 | return invokeReq |
| 114 | } |
| 115 | |
| 116 | func (s *RuntimeClient) waitRuntime(reqinfo *RequestInfo) (err error) { |
| 117 | runtime := reqinfo.Runtime |
no test coverage detected