Struct ElectionMysqlClient

pub struct ElectionMysqlClient {
    current: Option<PoolConnection<MySql>>,
    pool: MySqlPool,
    execution_timeout: Duration,
    max_execution_time: Duration,
    innode_lock_wait_timeout: Duration,
    wait_timeout: Duration,
    table_for_election: String,
}

MySQL client for election.

Fields

current: Option<PoolConnection<MySql>>

pool: MySqlPool

execution_timeout: Duration

The client-side timeout for statement execution.

This timeout is enforced by the client application and is independent of any server-side timeouts. If a statement takes longer than this duration to execute, the client will abort the operation.

max_execution_time: Duration

The maximum execution time for the statement.

This timeout is enforced by the server and is independent of any client-side timeouts. If a statement takes longer than this duration to execute, the server will abort the operation.

innode_lock_wait_timeout: Duration

The lock wait timeout for the session.

This timeout determines how long the server waits for a lock to be acquired before timing out. If a lock cannot be acquired within this duration, the server will abort the operation.

wait_timeout: Duration

The wait timeout for the session.

This timeout determines how long the server waits for activity on a noninteractive connection before closing it. If a connection is idle for longer than this duration, the server will terminate it.

table_for_election: String

The table name for election.

Implementations

impl ElectionMysqlClient

pub fn new( pool: MySqlPool, execution_timeout: Duration, max_execution_time: Duration, innode_lock_wait_timeout: Duration, wait_timeout: Duration, table_for_election: &str, ) -> Self

fn create_table_sql(&self) -> String

fn insert_once_sql(&self) -> String

fn check_version_sql(&self) -> String

async fn reset_client(&mut self) -> Result<()>

async fn ensure_table_exists(&mut self) -> Result<()>

async fn maybe_init_client(&mut self) -> Result<()>

async fn set_session_isolation_level(&mut self) -> Result<()>

Set session isolation level to serializable.

Panics

if current is None.

async fn check_version(&mut self, sql: &str) -> Result<()>

Check if the MySQL version is supported.

Panics

if current is None.

async fn execute( &mut self, query: Query<'_, MySql, MySqlArguments>, sql: &str, ) -> Result<u64>

Returns the result of the query.

Panics

if current is None.

async fn query( &mut self, query: Query<'_, MySql, MySqlArguments>, sql: &str, ) -> Result<Vec<MySqlRow>>

Returns the result of the query.

Panics

if current is None.

async fn transaction(&mut self) -> Result<TransactionWithExecutionTimeout<'_>>