Struct MockBackend 

pub struct MockBackend { /* private fields */ }

Implementations

impl MockBackend

pub fn new( checkpoint_token: &str, ) -> (Self, CheckpointRecorder, OperationRecorder)

Create a new MockBackend with the given checkpoint token.

Returns the backend, a checkpoint call recorder, and an operation sequence recorder for test assertions.

Examples

use durable_lambda_testing::mock_backend::MockBackend;

let (backend, calls, _ops) = MockBackend::new("token-123");
// calls can be inspected after running the handler

pub fn batch_call_counter(&self) -> BatchCallCounter

Return the batch checkpoint call counter for test assertions.

Trait Implementations

impl DurableBackend for MockBackend

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 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.

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).