Struct ConnectionRouter 

pub struct ConnectionRouter { /* private fields */ }

Connection router for read/write splitting.

Implementations

impl ConnectionRouter

pub fn new(config: ReplicaSetConfig) -> Self

Create a new router.

pub fn route( &self, query_type: QueryType, preference: Option<&ReadPreference>, ) -> QueryResult<&ReplicaConfig>

Get replica for a query based on query type and read preference.

pub fn get_primary(&self) -> QueryResult<&ReplicaConfig>

Get the primary replica.

pub fn update_health( &mut self, id: &str, status: HealthStatus, latency: Option<Duration>, lag: Option<Duration>, )

Update health status of a replica.

pub fn check_lag(&self, replica_id: &str, max_lag: Duration) -> bool

Check if replication lag is acceptable.

pub fn initiate_failover(&mut self) -> QueryResult<String>

Initiate failover to a new primary.

pub fn is_in_failover(&self) -> bool

Check if router is currently in failover mode.

Trait Implementations

impl Debug for ConnectionRouter

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

Formats the value using the given formatter.