Struct SentinelConnectionManager 

pub struct SentinelConnectionManager { /* private fields */ }

bb8 的 bb8::ManageConnection 实现。

内部持有 Arc<Mutex<SentinelClient>>，因为 SentinelClient::async_get_connection 需要 &mut self。建立新连接的时间通常是毫秒级，所以串行化并不会成为热路径瓶颈。

Implementations

impl SentinelConnectionManager

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

基于 SentinelPoolConfig 构造一个新的 manager。

pub fn bump_epoch(&self) -> u64

让所有当前在池里的连接立刻被识别为“已坏“。

后台 watcher 收到 +switch-master 事件时会调用本方法。也可以 在业务代码里手动调用，例如收到自定义运维信号时。

pub fn current_epoch(&self) -> u64

当前 epoch。

Trait Implementations

impl Clone for SentinelConnectionManager

fn clone(&self) -> SentinelConnectionManager

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl ManageConnection for SentinelConnectionManager

type Connection = PooledConnection

The connection type this manager deals with.

type Error = SentinelPoolError

The error type returned by Connections.

fn connect(&self) -> impl Future<Output = Result<Self::Connection>> + Send

Attempts to create a new connection.

fn is_valid( &self, conn: &mut Self::Connection, ) -> impl Future<Output = Result<()>> + Send

Determines if the connection is still connected to the database.

fn has_broken(&self, conn: &mut Self::Connection) -> bool

Synchronously determine if the connection is no longer usable, if possible.