(reqInfo *RequestInfo, logType string)
| 235 | } |
| 236 | |
| 237 | func (s *RuntimeClient) startRecvLog(reqInfo *RequestInfo, logType string) { |
| 238 | userID := reqInfo.Runtime.UserID |
| 239 | if userID == "" { |
| 240 | logs.Warn("user id is empty, set to unknown") |
| 241 | userID = "unknown" |
| 242 | } |
| 243 | params := LogStatStoreParameter{ |
| 244 | RequestID: reqInfo.RequestID, |
| 245 | TriggerType: reqInfo.TriggerType, |
| 246 | RuntimeID: reqInfo.Runtime.RuntimeID, |
| 247 | UserID: userID, |
| 248 | FunctionName: *reqInfo.Input.Configuration.FunctionName, |
| 249 | FunctionBrn: *reqInfo.Input.Configuration.FunctionArn, |
| 250 | FunctionVersion: *reqInfo.Input.Configuration.Version, |
| 251 | FilePath: s.dispatchServer.config.UserLogFileDir, |
| 252 | LogType: logType, |
| 253 | } |
| 254 | lss := newLogStatStore(¶ms) |
| 255 | s.dispatchServer.StartRecvLog(reqInfo.Runtime.RuntimeID, reqInfo.RequestID, lss) |
| 256 | reqInfo.SetLogStore(lss) |
| 257 | return |
| 258 | } |
no test coverage detected