Struct RetryManager 

pub struct RetryManager {
    Policy: RetryPolicy,
    Budgets: Arc<Mutex<HashMap<String, RetryBudget>>>,
    EventTx: Arc<Sender<RetryEvent>>,
}

Applies RetryPolicy: computes delays, tracks budgets per service, classifies errors, and publishes RetryEvents.

Fields

Policy: RetryPolicy

Budgets: Arc<Mutex<HashMap<String, RetryBudget>>>

EventTx: Arc<Sender<RetryEvent>>

Implementations

impl RetryManager

pub fn new(policy: RetryPolicy) -> Self

pub fn GetEventTransmitter(&self) -> Sender<RetryEvent>

pub fn CalculateRetryDelay(&self, Attempt: u32) -> Duration

Exponential backoff with jitter: base * multiplier^(attempt-1) + jitter.

pub fn CalculateAdaptiveRetryDelay( &self, ErrorType: &str, attempt: u32, ) -> Duration

Choose delay strategy based on classified error type.

pub fn ClassifyError(&self, ErrorMessage: &str) -> ErrorClass

pub async fn CanRetry(&self, service: &str) -> bool

pub fn PublishRetryEvent(&self, event: RetryEvent)

pub fn ValidatePolicy(&self) -> Result<(), String>

Trait Implementations

impl Debug for RetryManager

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.