Struct DurableExecutionInvocationOutput 

pub struct DurableExecutionInvocationOutput {
    pub status: InvocationStatus,
    pub result: Option<String>,
    pub error: Option<ErrorObject>,
}

Output payload for a durable execution Lambda invocation.

This struct is serialized and returned from the Lambda function to indicate the execution status.

Fields

status: InvocationStatus

The status of the invocation

result: Option<String>

The serialized result if the execution succeeded

error: Option<ErrorObject>

Error details if the execution failed

Implementations

impl DurableExecutionInvocationOutput

pub const MAX_RESPONSE_SIZE: usize

Maximum response size in bytes (6MB Lambda limit)

pub fn succeeded(result: Option<String>) -> Self

Creates a new output indicating successful completion.

pub fn failed(error: ErrorObject) -> Self

Creates a new output indicating failure.

pub fn pending() -> Self

Creates a new output indicating pending/suspended execution.

pub fn is_succeeded(&self) -> bool

Returns true if the invocation succeeded.

pub fn is_failed(&self) -> bool

Returns true if the invocation failed.

pub fn is_pending(&self) -> bool

Returns true if the invocation is pending.

pub fn from_result<T: Serialize>(result: &T) -> Self

Creates an output from a serializable result.

This method handles:

• Serializing the result to JSON
• Checking if the response exceeds the maximum size
• Returning appropriate error if serialization fails

Arguments

• result - The result to serialize

Returns

A DurableExecutionInvocationOutput with:

• SUCCEEDED status if serialization succeeds and size is within limits
• FAILED status if serialization fails or response is too large

pub fn from_error(error: &DurableError) -> Self

Creates an output from a DurableError.

This method handles different error types:

• Suspend errors return PENDING status
• All other errors return FAILED status with error details

Arguments

• error - The error to convert

Returns

A DurableExecutionInvocationOutput with appropriate status

pub fn would_exceed_max_size<T: Serialize>(result: &T) -> bool

Checks if a result would exceed the maximum response size.

This is useful for determining if a result should be checkpointed before returning.

Arguments

• result - The result to check

Returns

true if the serialized result would exceed the maximum size

pub fn checkpointed_result(checkpoint_id: &str, original_size: usize) -> Self

Creates an output for a large result that has been checkpointed.

This method creates a SUCCEEDED output with a reference to the checkpointed result, rather than the result itself.

Arguments

• checkpoint_id - The operation ID where the result was checkpointed
• original_size - The size of the original serialized result in bytes

Returns

A DurableExecutionInvocationOutput with SUCCEEDED status and a reference to the checkpointed result.

pub fn is_checkpointed_result(&self) -> bool

Checks if this output represents a checkpointed large result.

Returns

true if this output contains a reference to a checkpointed result

Trait Implementations

impl Clone for DurableExecutionInvocationOutput

fn clone(&self) -> DurableExecutionInvocationOutput

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for DurableExecutionInvocationOutput

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl From<Result<Option<String>, ErrorObject>> for DurableExecutionInvocationOutput

fn from(result: Result<Option<String>, ErrorObject>) -> Self

Converts to this type from the input type.

impl From<Result<String, ErrorObject>> for DurableExecutionInvocationOutput

fn from(result: Result<String, ErrorObject>) -> Self

Converts to this type from the input type.

impl Serialize for DurableExecutionInvocationOutput

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.