Struct DefaultCircuitBreaker 

pub struct DefaultCircuitBreaker { /* private fields */ }

默认断路器实现

提供 failure_threshold（连续失败阈值）+ reset_timeout（重置超时）的经典三态机。

示例

use sz_orm_pool::circuit_breaker::{CircuitBreaker, CircuitState, DefaultCircuitBreaker};
use std::time::Duration;

let mut cb = DefaultCircuitBreaker::new(3, Duration::from_secs(60));
assert_eq!(cb.state(), CircuitState::Closed);
assert!(cb.can_execute());

// 3 次失败后跳闸
cb.record_failure();
cb.record_failure();
cb.record_failure();
assert_eq!(cb.state(), CircuitState::Open);
assert!(!cb.can_execute());

// 一次成功后恢复
cb.record_success();
assert_eq!(cb.state(), CircuitState::Closed);

Implementations

impl DefaultCircuitBreaker

pub fn new( failure_threshold: usize, reset_timeout: Duration, ) -> DefaultCircuitBreaker

创建默认断路器

• failure_threshold：连续失败次数阈值（>= 时跳闸）
• reset_timeout：Open 状态持续时间，到达后进入 HalfOpen

pub fn consecutive_failures(&self) -> usize

获取连续失败次数（主要用于测试与监控）

pub fn failure_threshold(&self) -> usize

获取失败阈值

pub fn reset_timeout(&self) -> Duration

获取重置超时

Trait Implementations

impl CircuitBreaker for DefaultCircuitBreaker

fn state(&self) -> CircuitState

获取当前断路器状态

fn record_success(&mut self)

记录一次成功请求

fn record_failure(&mut self)

记录一次失败请求

fn can_execute(&mut self) -> bool

判断当前是否允许请求通过

fn reset(&mut self) -> bool

手动重置断路器到 Closed 状态

impl Debug for DefaultCircuitBreaker

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

Formats the value using the given formatter.

impl Default for DefaultCircuitBreaker

fn default() -> DefaultCircuitBreaker

默认配置：5 次连续失败跳闸，30 秒后进入 HalfOpen