Struct CircuitBreakerExecutor 

pub struct CircuitBreakerExecutor<S> { /* private fields */ }

给任意 SqlExecutor 包一层熔断。

每个端点各包一个 —— 不是包在路由外层：那样单个从库故障会误熔断整条链路 （spec:225）。熔断打开时内层一次都不会被调用。

Implementations

impl<S> CircuitBreakerExecutor<S>

pub fn new(inner: S, cfg: BreakerConfig) -> Self

pub fn state(&self) -> BreakerState

供 RdbmsRouting 跳过已熔断的端点。

pub fn inner(&self) -> &S

Trait Implementations

impl<S: RdbmsClient> RdbmsClient for CircuitBreakerExecutor<S>

fn transaction<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Transaction, RdbmsError>> + Send + 'async_trait>>

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

事务不经熔断，直接委托内层。

两件事要分清：

• 把熔断套到事务上 —— 要在 TransactionInner 层面再包一层，代价大于收益（不做）
• 把 transaction() 委托给内层 —— 就是这三行（要做）：端点要能装进 Arc<dyn RdbmsClient>，而事务天然走 primary，失败由 SQL 层报错。

impl<S: SqlExecutor> SqlExecutor for CircuitBreakerExecutor<S>

fn query_write<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, sql: &'life1 str, params: &'life2 [Value], ) -> Pin<Box<dyn Future<Output = Result<Vec<Row>, RdbmsError>> + Send + 'async_trait>>

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

写路径的返回行查询：同样受熔断保护 —— 熔断打开的端点连写也不该碰。

fn dialect(&self) -> Dialect

纯本地判断，不会失败，也不该被「熔断」影响 —— 直接委托。

fn execute<'life0, 'life1, 'async_trait>( &'life0 self, sql: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<u64, RdbmsError>> + Send + 'async_trait>>

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

执行一条 SQL 语句，返回受影响行数。 用户提供的值请走 SqlExecutor::execute_with。

fn query<'life0, 'life1, 'async_trait>( &'life0 self, sql: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<Row>, RdbmsError>> + Send + 'async_trait>>

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

查询多行。用户提供的值请走 SqlExecutor::query_with。

fn execute_with<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, sql: &'life1 str, params: &'life2 [Value], ) -> Pin<Box<dyn Future<Output = Result<u64, RdbmsError>> + Send + 'async_trait>>

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

参数化执行，防注入。无法绑定参数的后端返回错误。

fn query_with<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, sql: &'life1 str, params: &'life2 [Value], ) -> Pin<Box<dyn Future<Output = Result<Vec<Row>, RdbmsError>> + Send + 'async_trait>>

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

参数化查询，防注入。无法绑定参数的后端返回错误。

fn execute_then_query<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, first: &'life1 str, first_params: &'life2 [Value], second: &'life3 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<Row>, RdbmsError>> + Send + 'async_trait>>

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

在同一条连接上先执行 first、再执行 second（查询），两者原子。