Struct LambdaDurableServiceClient 

pub struct LambdaDurableServiceClient { /* private fields */ }

Lambda-based implementation of the DurableServiceClient.

This client uses the AWS Lambda REST APIs (CheckpointDurableExecution and GetDurableExecutionState) to communicate with the durable execution service.

Implementations

impl LambdaDurableServiceClient

pub async fn from_env() -> Self

Creates a new LambdaDurableServiceClient from AWS config.

pub fn from_aws_config(aws_config: &SdkConfig) -> Self

Creates a new LambdaDurableServiceClient from AWS SDK config.

pub fn from_aws_config_with_user_agent( aws_config: &SdkConfig, sdk_name: &str, sdk_version: &str, ) -> Self

Creates a new LambdaDurableServiceClient from AWS SDK config with a custom user-agent string appended to HTTP requests for SDK identification.

pub fn with_config( credentials_provider: Arc<dyn ProvideCredentials>, config: LambdaClientConfig, ) -> Self

Creates a new LambdaDurableServiceClient with custom configuration.

pub fn new(_lambda_client: Client) -> Self

Creates a new LambdaDurableServiceClient with a Lambda client (for backward compatibility). Note: This extracts the region from the Lambda client but uses direct HTTP calls.

IMPORTANT: This method requires that the Lambda client was created with credentials. If you’re using this in a Lambda function, prefer using from_env() instead.

Trait Implementations

impl DurableServiceClient for LambdaDurableServiceClient

fn checkpoint<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, durable_execution_arn: &'life1 str, checkpoint_token: &'life2 str, operations: Vec<OperationUpdate>, ) -> Pin<Box<dyn Future<Output = Result<CheckpointResponse, DurableError>> + Send + 'async_trait>>

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

Sends a batch of checkpoint operations to the service.

fn get_operations<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, durable_execution_arn: &'life1 str, next_marker: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<GetOperationsResponse, DurableError>> + Send + 'async_trait>>

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

Retrieves additional operations for pagination.