(id: &str, event: &InvokeRequest)
| 89 | |
| 90 | impl NextEvent { |
| 91 | pub fn invoke(id: &str, event: &InvokeRequest) -> NextEvent { |
| 92 | let tracing_id = event |
| 93 | .req |
| 94 | .headers() |
| 95 | .get(AWS_XRAY_TRACE_HEADER) |
| 96 | .and_then(|h| h.to_str().ok()) |
| 97 | .unwrap_or_default(); |
| 98 | |
| 99 | let e = InvokeEvent { |
| 100 | request_id: id.to_string(), |
| 101 | invoked_function_arn: event.function_name.clone(), |
| 102 | tracing: Tracing { |
| 103 | r#type: AWS_XRAY_TRACE_HEADER.to_string(), |
| 104 | value: tracing_id.to_string(), |
| 105 | }, |
| 106 | ..Default::default() |
| 107 | }; |
| 108 | |
| 109 | NextEvent::Invoke(e) |
| 110 | } |
| 111 | |
| 112 | pub fn shutdown(reason: &str) -> NextEvent { |
| 113 | NextEvent::Shutdown(ShutdownEvent { |
no test coverage detected