Struct ConsecutiveFailures 

pub struct ConsecutiveFailures { /* private fields */ }

Available on crate feature circuit-breaker only.

A CircuitPolicy that opens the circuit after N consecutive failures and closes it again once a sufficient fraction of probes succeed.

Parameters

Parameter	Description
failure_threshold	Number of consecutive failures needed to open the circuit.
success_threshold	Fraction of HalfOpen probes (0.0–1.0) that must succeed to close.
timeout	How long to stay Open before sending the first probe.

Example

use tower::circuit_breaker::{CircuitBreakerLayer, ConsecutiveFailures};
use std::time::Duration;

let policy = ConsecutiveFailures::new(5, 0.8, Duration::from_secs(30));
let layer  = CircuitBreakerLayer::with_policy(policy);

Implementations

impl ConsecutiveFailures

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

Create a new ConsecutiveFailures policy.

Trait Implementations

impl CircuitPolicy for ConsecutiveFailures

fn on_success(&mut self) -> bool

Called after a successful response from the inner service.

fn on_failure(&mut self) -> bool

Called after a failed response from the inner service.

fn should_probe(&self) -> bool

Called while the circuit is Open.

fn on_half_open(&mut self)

Called immediately after the circuit transitions to HalfOpen.

impl Clone for ConsecutiveFailures

fn clone(&self) -> ConsecutiveFailures

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ConsecutiveFailures

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

Formats the value using the given formatter.