Struct DeadLetterEngine 

pub struct DeadLetterEngine { /* private fields */ }

Intelligent dead letter management engine.

Implementations

impl DeadLetterEngine

pub fn new() -> Self

pub fn add_item( &mut self, execution_id: &str, workflow_id: &str, step_id: &str, failure_class: &str, error_message: &str, input_data: Value, attempt_count: u32, ) -> WorkflowResult<String>

Add a failed item to the dead letter queue.

pub fn list_items(&self) -> Vec<&DeadLetterItem>

List all dead letter items.

pub fn summary(&self) -> DeadLetterSummary

Get a summary grouped by failure class.

pub fn remove_item(&mut self, item_id: &str) -> WorkflowResult<DeadLetterItem>

Remove an item (after successful retry or manual resolution).

pub fn purge_expired(&mut self) -> usize

Purge expired items.

pub fn retryable_items(&self, failure_class: &str) -> Vec<&DeadLetterItem>

Get items that can be auto-retried (for service recovery).

pub fn set_policy(&mut self, policy: DeadLetterPolicy)

Update retention policy.

pub fn get_policy(&self) -> &DeadLetterPolicy

Get current policy.

Trait Implementations

impl Default for DeadLetterEngine

fn default() -> Self

Returns the “default value” for a type.