Struct LambdaScheduledRecoveryHandler 

pub struct LambdaScheduledRecoveryHandler { /* private fields */ }

Handler for scheduled push-recovery ticks.

Construct once per Lambda cold start; invoke per scheduled event.

Implementations

impl LambdaScheduledRecoveryHandler

pub const ERROR_SAMPLE_LIMIT: usize = 8

Cap on errors in a single response so Lambda doesn’t return megabytes of stringified errors under a persistent outage.

pub fn new( dispatcher: Arc<PushDispatcher>, delivery_store: Arc<dyn A2aPushDeliveryStore>, ) -> Self

pub fn with_config(self, config: LambdaScheduledRecoveryConfig) -> Self

pub async fn handle_scheduled_event( &self, _event: EventBridgeEvent, ) -> LambdaScheduledRecoveryResponse

Run one recovery sweep. The _event argument is accepted so the signature matches lambda_runtime::service_fn; the EventBridge payload is not inspected — each invocation is one tick regardless of cron metadata.

pub async fn run_sweep(&self) -> LambdaScheduledRecoveryResponse

Testable entry point. Runs the full sweep and returns a summary. External callers almost always want Self::handle_scheduled_event; this method is exposed so unit tests can exercise the recovery logic without constructing an EventBridgeEvent.

Trait Implementations

impl Clone for LambdaScheduledRecoveryHandler

fn clone(&self) -> LambdaScheduledRecoveryHandler

Returns a duplicate of the value.

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

Performs copy-assignment from source.