Struct CircuitBreaker 

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

Circuit breaker for fault isolation.

Fields

config: CircuitBreakerConfig

state: RwLock<RawRwLock, CircuitState>

failure_count: AtomicU32

success_count: AtomicU32

opened_at: RwLock<RawRwLock, Option<Instant>>

half_open_requests: AtomicU32

total_requests: AtomicU64

total_failures: AtomicU64

total_rejections: AtomicU64

Implementations

impl CircuitBreaker

pub fn new() -> Arc<CircuitBreaker>

Create a new circuit breaker with default config.

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

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).

pub fn reset(&self)

Force reset the circuit to closed state.

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

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() -> CircuitBreaker

Returns the “default value” for a type.