pub fn parse_invocation(payload: &Value) -> Result<InvocationData, &'static str>Expand description
Parse all durable execution fields from a Lambda event payload.
Extracts ARN, checkpoint token, initial operations, pagination marker, and user event from the standard durable Lambda event envelope.
§Arguments
payload- The raw Lambda event payload as JSON
§Errors
Returns Err(&'static str) if DurableExecutionArn or CheckpointToken
is missing from the payload.
§Examples
let payload = serde_json::json!({
"DurableExecutionArn": "arn:aws:lambda:us-east-1:123:durable-execution/test",
"CheckpointToken": "tok-1",
"InitialExecutionState": {
"Operations": [{
"Id": "exec-1",
"Type": "Execution",
"Status": "Started",
"ExecutionDetails": { "InputPayload": "{\"order_id\": 42}" }
}]
}
});
let data = durable_lambda_core::event::parse_invocation(&payload).unwrap();
assert_eq!(data.checkpoint_token, "tok-1");
assert_eq!(data.user_event["order_id"], 42);