Struct RetryEngine 

pub struct RetryEngine { /* private fields */ }

Failure-classified retry engine.

Implementations

impl RetryEngine

pub fn new() -> Self

pub fn configure_policy( &mut self, name: &str, profiles: Vec<RetryProfile>, budget: Option<RetryBudget>, ) -> WorkflowResult<String>

Configure a retry policy.

pub fn get_policy(&self, policy_id: &str) -> WorkflowResult<&RetryPolicy>

Get a retry policy.

pub fn get_profile_for_failure( &self, policy_id: &str, failure_class: &FailureClass, ) -> WorkflowResult<Option<&RetryProfile>>

Get retry profile for a specific failure class.

pub fn calculate_delay(&self, strategy: &RetryStrategy, attempt: u32) -> u64

Calculate delay for next retry attempt.

pub fn within_budget( &self, policy_id: &str, step_id: &str, ) -> WorkflowResult<bool>

Check if retry is within budget.

pub fn record_attempt(&mut self, step_id: &str, failure_class: FailureClass)

Record a retry attempt.

pub fn get_stats(&self, step_id: &str) -> Option<&RetryStats>

Get retry stats for a step.

pub fn get_patterns(&self) -> Vec<RetryPattern>

Get learned retry patterns.

pub fn list_policies(&self) -> Vec<&RetryPolicy>

List all policies.

Trait Implementations

impl Default for RetryEngine

fn default() -> Self

Returns the “default value” for a type.