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() -> Result<Self, DurableError>

Creates a new LambdaDurableServiceClient from AWS config.

Errors

Returns DurableError::Configuration if no credentials provider is configured.

pub fn from_aws_config(aws_config: &SdkConfig) -> Result<Self, DurableError>

Creates a new LambdaDurableServiceClient from AWS SDK config.

Errors

Returns DurableError::Configuration if no credentials provider is configured.

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

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

Errors

Returns DurableError::Configuration if no credentials provider is configured.

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

Creates a new LambdaDurableServiceClient with custom configuration.

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.