Struct ElectionPgClient 

pub struct ElectionPgClient {
    current: Option<Object<Manager>>,
    pool: Pool,
    execution_timeout: Duration,
    idle_session_timeout: Duration,
    statement_timeout: Duration,
}

PgClient for election.

The session is dedicated to election and candidate registration. It must not hold unrelated advisory locks, as stepping down releases all session locks.

Fields

current: Option<Object<Manager>>

pool: Pool

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.

idle_session_timeout: Duration

The idle session timeout.

This timeout is configured per client session and is enforced by the PostgreSQL server. If a session remains idle for longer than this duration, the server will terminate it.

statement_timeout: Duration

The statement timeout.

This timeout is configured per client session and is enforced by the PostgreSQL server. If a statement takes longer than this duration to execute, the server will abort it.

Implementations

impl ElectionPgClient

pub fn new( pool: Pool, execution_timeout: Duration, idle_session_timeout: Duration, statement_timeout: Duration, ) -> Result<ElectionPgClient>

fn set_idle_session_timeout_sql(&self) -> String

fn set_statement_timeout_sql(&self) -> String

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

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

async fn execute( &self, sql: &str, params: &[&(dyn ToSql + Sync)], ) -> Result<u64>

Returns the result of the query.

Panics

if current is None.

async fn query( &self, sql: &str, params: &[&(dyn ToSql + Sync)], ) -> Result<Vec<Row>>

Returns the result of the query.

Panics

if current is None.