Struct SentinelPool 

pub struct SentinelPool { /* private fields */ }

Sentinel 感知的异步连接池。

内部封装 bb8::Pool，并暴露常用的便捷方法。SentinelPool 是 Clone 的， 克隆开销极低（只克隆几个 Arc），适合在不同 task 之间随手传递。

Implementations

impl SentinelPool

pub async fn new(config: SentinelPoolConfig) -> Result<Self>

基于配置构建连接池。

该方法是 async 的，因为 bb8::Pool::build 在 min_idle > 0 时 会立刻预热相应数量的连接。

pub fn config(&self) -> &SentinelPoolConfig

当前配置的只读视图。

pub fn inner_pool(&self) -> &Pool<SentinelConnectionManager>

暴露底层 bb8::Pool，用于细粒度操作（如 state() 监控）。

pub fn epoch(&self) -> u64

当前的 master epoch；每次 failover 后会递增。

pub fn force_refresh(&self) -> u64

主动让池里所有连接立刻失效。

通常你不需要调用它 —— 后台 watcher 会自动处理。但例如在做演练、压测， 或者收到自己运维系统的信号时，可以手动调用以触发刷新。

pub async fn get(&self) -> Result<ConnectionLease<'_>>

从池中借一条到 当前 master 的连接。

返回的 ConnectionLease 在 drop 时自动归还连接。如果归还前底层 连接已经损坏，会被自动丢弃，下次借用时由 manager 重新建立。

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

where F: FnMut(MultiplexedConnection) -> Fut, Fut: Future<Output = Result<T, RedisError>>,

在一条新借来的连接上执行闭包，并按配置自动重试。

适合“业务侧根本不想关心 failover“的场景。重试逻辑：

1. 调用 SentinelPool::get 拿连接；
2. 执行闭包，成功就返回；
3. 失败且错误看起来像连接级错误（IO / 已断开 / READONLY 等）时， 主动 force_refresh 后重试；
4. 重试次数耗尽返回 SentinelPoolError::RetryExhausted。

pub async fn shutdown(self)

优雅关闭：停止后台 watcher 并等待退出。

池本身在最后一个 SentinelPool 实例被 drop 时由 bb8 内部释放。

Trait Implementations

impl Clone for SentinelPool

fn clone(&self) -> SentinelPool

Returns a duplicate of the value.

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

Performs copy-assignment from source.