Skip to main content

parse_invocation

Function parse_invocation 

Source
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);