Struct CircuitBreaker 

pub struct CircuitBreaker {
    config: CircuitBreakerConfig,
    state: RwLock<CircuitState>,
    failure_count: AtomicU32,
    success_count: AtomicU32,
    opened_at: RwLock<Option<Instant>>,
    half_open_requests: AtomicU32,
    total_requests: AtomicU64,
    total_failures: AtomicU64,
    total_rejections: AtomicU64,
}

Circuit breaker for fault isolation.

Fields

config: CircuitBreakerConfig

Configuration.

state: RwLock<CircuitState>

Current state.

failure_count: AtomicU32

Failure count in current window.

success_count: AtomicU32

Success count in half-open state.

opened_at: RwLock<Option<Instant>>

Time when circuit opened.

half_open_requests: AtomicU32

Current requests in half-open state.

total_requests: AtomicU64

Total requests.

total_failures: AtomicU64

Total failures.

total_rejections: AtomicU64

Total rejections (due to open circuit).

Implementations

impl CircuitBreaker

pub fn new() -> Arc<Self>

Create a new circuit breaker with default config.

pub fn with_config(config: CircuitBreakerConfig) -> Arc<Self>

Create with custom config.

pub fn state(&self) -> CircuitState

Get current state.

pub fn is_allowed(&self) -> bool

Check if circuit allows requests.

pub fn record_success(&self)

Record a successful operation.

pub fn record_failure(&self)

Record a failed operation.

pub fn record_rejection(&self)

Record a rejection (request not attempted due to open circuit).

fn open(&self)

Open the circuit.

fn close(&self)

Close the circuit.

pub fn reset(&self)

Force reset the circuit to closed state.

fn acquire_half_open(&self) -> bool

Acquire permission to execute (for half-open state).

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

where F: FnOnce() -> Fut, Fut: Future<Output = Result<T, E>>, E: Display,

Execute an operation with circuit breaker protection.

pub fn stats(&self) -> CircuitBreakerStats

Get circuit breaker statistics.

Trait Implementations

impl Default for CircuitBreaker

fn default() -> Self

Returns the “default value” for a type.