Struct CircuitBreaker 

pub struct CircuitBreaker { /* private fields */ }

Thread-safe circuit breaker implementation

Implementations

impl CircuitBreaker

pub fn new( name: &str, failure_threshold: usize, open_duration: Duration, ) -> Self

Create a new circuit breaker

• name: Identifier for this circuit (e.g., “arxiv”)
• failure_threshold: Failures before opening (default: 5)
• open_duration: Time to stay open before half-open (default: 60s)

pub fn default_for(name: &str) -> Self

Create with default settings

pub fn state(&self) -> CircuitState

Get the current state

pub fn record_success(&self)

Record a success

pub fn record_failure(&self)

Record a failure

pub fn can_request(&self) -> bool

Check if a request should be allowed

pub async fn execute<F, T, E>(&self, operation: F) -> CircuitResult<T>

where F: Future<Output = Result<T, E>>, E: Display,

Execute an async operation with circuit breaker protection

Returns CircuitResult::Rejected if the circuit is open.

pub fn reset(&self)

Reset the circuit breaker to closed state

Trait Implementations

impl Debug for CircuitBreaker

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

Formats the value using the given formatter.