Struct InMemoryCircuitBreakerBackend 

pub struct InMemoryCircuitBreakerBackend { /* private fields */ }

In-process circuit breaker backend backed by a Mutex<HashMap>.

Each service name gets its own independent failure counter and open-at timestamp. Multiple CircuitBreaker instances that share the same backend (via CircuitBreaker::with_backend) will correctly track failures per service rather than sharing a single counter.

Implementations

impl InMemoryCircuitBreakerBackend

pub fn new() -> Self

Create a new in-memory backend with all counters at zero.

Trait Implementations

impl AsyncCircuitBreakerBackend for InMemoryCircuitBreakerBackend

fn increment_failures<'life0, 'life1, 'async_trait>( &'life0 self, service: &'life1 str, ) -> Pin<Box<dyn Future<Output = u32> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Increment the consecutive failure count and return the new count.

fn reset_failures<'life0, 'life1, 'async_trait>( &'life0 self, service: &'life1 str, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Reset the consecutive failure count to zero.

fn get_failures<'life0, 'life1, 'async_trait>( &'life0 self, service: &'life1 str, ) -> Pin<Box<dyn Future<Output = u32> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Return the current consecutive failure count.

fn set_open_at<'life0, 'life1, 'async_trait>( &'life0 self, service: &'life1 str, at: Instant, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Record the instant at which the circuit was opened.

fn clear_open_at<'life0, 'life1, 'async_trait>( &'life0 self, service: &'life1 str, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Clear the open-at timestamp.

fn get_open_at<'life0, 'life1, 'async_trait>( &'life0 self, service: &'life1 str, ) -> Pin<Box<dyn Future<Output = Option<Instant>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Return the instant at which the circuit was opened, or None.

impl CircuitBreakerBackend for InMemoryCircuitBreakerBackend

fn increment_failures(&self, service: &str) -> u32

Increment the consecutive failure count for service and return the new count.

fn reset_failures(&self, service: &str)

Reset the consecutive failure count for service to zero.

fn get_failures(&self, service: &str) -> u32

Return the current consecutive failure count for service.

fn set_open_at(&self, service: &str, at: Instant)

Record the instant at which the circuit was opened for service.

fn clear_open_at(&self, service: &str)

Clear the open-at timestamp, effectively moving the circuit to Closed or HalfOpen.

fn get_open_at(&self, service: &str) -> Option<Instant>

Return the instant at which the circuit was opened, or None if it is not open.

impl Default for InMemoryCircuitBreakerBackend

fn default() -> Self

Returns the “default value” for a type.