InvokeFunc
(request *RequestInfo, invokeReq *InvokeHTTPRequest)
| 403 | |
| 404 | // InvokeFunc |
| 405 | func (info *RuntimeInfo) InvokeHTTPFunc(request *RequestInfo, invokeReq *InvokeHTTPRequest) error { |
| 406 | info.requestMap.Store(request.RequestID, request) |
| 407 | |
| 408 | select { |
| 409 | case info.httpRequestChan <- invokeReq: |
| 410 | default: |
| 411 | return errors.New("request queue is full") |
| 412 | } |
| 413 | |
| 414 | return nil |
| 415 | } |
| 416 | |
| 417 | // TODO: Add a timer to recreate the client ? |
| 418 | func (info *RuntimeInfo) getHTTPClient() *http.Client { |