Struct LambdaStreamRecoveryHandler 

pub struct LambdaStreamRecoveryHandler { /* private fields */ }

Handler for DynamoDB Stream events on a2a_push_pending_dispatches.

Construct once per Lambda cold start; reuse across invocations. The handler holds an Arc<PushDispatcher> — the same dispatcher the request-Lambda builds when push_delivery_store is wired, so you can share one state bundle across both entry points.

Implementations

impl LambdaStreamRecoveryHandler

pub fn new(dispatcher: Arc<PushDispatcher>) -> Self

pub async fn handle_stream_event( &self, event: DynamoDbEvent, ) -> DynamoDbEventResponse

Handle a batch of DynamoDB Stream records. Returns the DynamoDbEventResponse with BatchItemFailures populated for records whose redispatch hit a transient error or whose NEW_IMAGE could not be parsed. Records with a missing SequenceNumber are skipped with a log warning — they cannot be surfaced in BatchItemFailures (the field is required by the Lambda service to identify the record to retry).

Trait Implementations

impl Clone for LambdaStreamRecoveryHandler

fn clone(&self) -> LambdaStreamRecoveryHandler

Returns a duplicate of the value.

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

Performs copy-assignment from source.