Struct RetryEngine 

pub struct RetryEngine { /* private fields */ }

Runtime retry state for all connections.

Implementations

impl RetryEngine

pub fn new() -> Self

pub fn classify_http_status(status: u16) -> FailureClass

Classify an HTTP status code into a failure class.

pub fn classify_error(error: &str) -> FailureClass

Classify a connection error string.

pub fn strategy_for(class: FailureClass) -> RetryStrategy

Get the retry strategy for a failure class.

pub fn get_circuit(&mut self, endpoint: &str) -> &CircuitBreaker

Get or create a circuit breaker for an endpoint.

pub fn record_failure( &mut self, endpoint: &str, class: FailureClass, message: &str, status: Option<u16>, )

Record a failure for an endpoint.

pub fn record_success(&mut self, endpoint: &str)

Record a success for an endpoint.

pub fn should_allow(&self, endpoint: &str) -> bool

Check if a request to this endpoint should be allowed.

pub fn update_rate_limit( &mut self, endpoint: &str, limit: u32, remaining: u32, reset_epoch: i64, )

Update rate limit tracking from response headers.

pub fn rate_limit_status(&self, endpoint: &str) -> Option<&RateLimitWindow>

Get rate limit status for an endpoint.

pub fn all_circuits(&self) -> &HashMap<String, CircuitBreaker>

Get all circuit breaker states.

pub fn reset_circuit(&mut self, endpoint: &str) -> bool

Reset a circuit breaker.

pub fn failure_patterns(&self, endpoint: &str) -> Vec<&FailureRecord>

Get failure patterns for an endpoint.

pub fn recent_failures(&self, limit: usize) -> Vec<&FailureRecord>

Get all recent failures.

Trait Implementations

impl Default for RetryEngine

fn default() -> Self

Returns the “default value” for a type.