Struct RealBackend 

pub struct RealBackend { /* private fields */ }

Real AWS backend that calls aws-sdk-lambda durable execution APIs.

Implements DurableBackend with exponential backoff retry for transient AWS failures (throttling, server errors, timeouts).

Examples

use aws_sdk_lambda::Client;
use durable_lambda_core::backend::RealBackend;

let config = aws_config::load_defaults(aws_config::BehaviorVersion::latest()).await;
let client = Client::new(&config);
let backend = RealBackend::new(client);

Implementations

impl RealBackend

pub fn new(client: Client) -> Self

Create a new RealBackend wrapping an aws-sdk-lambda client.

Examples

use aws_sdk_lambda::Client;
use durable_lambda_core::backend::RealBackend;

let config = aws_config::load_defaults(aws_config::BehaviorVersion::latest()).await;
let client = Client::new(&config);
let backend = RealBackend::new(client);

Trait Implementations

impl DurableBackend for RealBackend

fn checkpoint<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, arn: &'life1 str, checkpoint_token: &'life2 str, updates: Vec<OperationUpdate>, client_token: Option<&'life3 str>, ) -> Pin<Box<dyn Future<Output = Result<CheckpointDurableExecutionOutput, DurableError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Persist checkpoint updates for a durable execution.

fn get_execution_state<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, arn: &'life1 str, checkpoint_token: &'life2 str, next_marker: &'life3 str, max_items: i32, ) -> Pin<Box<dyn Future<Output = Result<GetDurableExecutionStateOutput, DurableError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Get the current operation state of a durable execution (paginated).

fn batch_checkpoint<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, arn: &'life1 str, checkpoint_token: &'life2 str, updates: Vec<OperationUpdate>, client_token: Option<&'life3 str>, ) -> Pin<Box<dyn Future<Output = Result<CheckpointDurableExecutionOutput, DurableError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Persist multiple checkpoint updates in a single AWS API call.