Struct PgsqlTransactionManager 

pub struct PgsqlTransactionManager { /* private fields */ }

Implementations

impl PgsqlTransactionManager

pub fn new(timeout_secs: u64) -> Self

pub fn is_in_transaction(&self, key: &str) -> bool

pub fn get_depth(&self, key: &str) -> i32

pub fn increment_depth(&self, key: &str) -> bool

pub fn start(&self, key: &str, conn: Connect) -> bool

pub fn with_conn<F, R>(&self, key: &str, f: F) -> Option<R>

where F: FnOnce(&mut Connect) -> R,

pub fn acquire_table_lock( &self, table: &str, thread_id: &str, timeout: Duration, ) -> bool

pub fn release_table_lock(&self, table: &str, thread_id: &str)

pub fn release_all_table_locks(&self, thread_id: &str)

pub fn decrement_or_finish(&self, key: &str, thread_id: &str) -> Option<i32>

pub fn remove(&self, key: &str, thread_id: &str)

pub fn cleanup_expired(&self)

pub fn stats(&self) -> (usize, usize)