Struct CircuitBreakerAspect 

pub struct CircuitBreakerAspect { /* private fields */ }

Circuit breaker aspect for preventing cascading failures.

Implements the circuit breaker pattern to protect services from repeated failures and allow time for recovery.

States

• Closed: Normal operation, failures are tracked
• Open: Fast-fail mode after threshold is exceeded
• Half-Open: Testing recovery with limited requests

Example

use aspect_std::CircuitBreakerAspect;
use aspect_macros::aspect;
use std::time::Duration;

// Open after 5 failures, timeout after 30 seconds
let breaker = CircuitBreakerAspect::new(5, Duration::from_secs(30));

#[aspect(breaker.clone())]
fn call_external_service() -> Result<String, String> {
    // This call is protected by the circuit breaker
    Ok("success".to_string())
}

Implementations

impl CircuitBreakerAspect

pub fn new(failure_threshold: usize, timeout: Duration) -> Self

Create a new circuit breaker.

Arguments

• failure_threshold - Number of failures before opening circuit
• timeout - How long to wait before attempting recovery

Example

use aspect_std::CircuitBreakerAspect;
use std::time::Duration;

let breaker = CircuitBreakerAspect::new(5, Duration::from_secs(30));

pub fn with_half_open_requests(self, max_requests: usize) -> Self

Set the maximum number of requests to allow in half-open state.

pub fn state(&self) -> CircuitState

Get the current circuit state.

pub fn reset(&self)

Manually reset the circuit breaker to closed state.

Trait Implementations

impl Aspect for CircuitBreakerAspect

fn around( &self, pjp: ProceedingJoinPoint<'_>, ) -> Result<Box<dyn Any>, AspectError>

Advice that wraps the entire target function execution.

fn before(&self, _ctx: &JoinPoint)

Advice executed before the target function runs.

fn after(&self, _ctx: &JoinPoint, _result: &(dyn Any + 'static))

Advice executed after the target function completes successfully.

fn after_error(&self, _ctx: &JoinPoint, _error: &AspectError)

Advice executed when the target function encounters an error.

impl Clone for CircuitBreakerAspect

fn clone(&self) -> CircuitBreakerAspect

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.