(reqInfo *RequestInfo, input *InvocationInput)
| 218 | } |
| 219 | |
| 220 | func (s *RuntimeClient) InvokeFunc(reqInfo *RequestInfo, input *InvocationInput) (err error) { |
| 221 | if input.WithStreamMode { |
| 222 | invokeRequest := s.makeInvokeHTTPRequest(reqInfo, input) |
| 223 | reqInfo.InvokeStart() |
| 224 | err = input.Runtime.InvokeHTTPFunc(reqInfo, invokeRequest) |
| 225 | reqInfo.StepDone(StageInvokeFunc) |
| 226 | } else { |
| 227 | invokeReq := s.makeInvokeRequest(input) |
| 228 | reqInfo.InvokeStart() |
| 229 | err = input.Runtime.InvokeFunc(reqInfo, invokeReq) |
| 230 | reqInfo.StepDone(StageInvokeFunc) |
| 231 | reqInfo.CleanInput() |
| 232 | invokeReq = nil |
| 233 | } |
| 234 | return |
| 235 | } |
| 236 | |
| 237 | func (s *RuntimeClient) startRecvLog(reqInfo *RequestInfo, logType string) { |
| 238 | userID := reqInfo.Runtime.UserID |
no test coverage detected