Struct SqliteTransactionManager 

pub struct SqliteTransactionManager { /* private fields */ }

Implementations

impl SqliteTransactionManager

pub fn new(timeout_secs: u64) -> Self

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

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

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

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

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

pub fn start(&self, key: &str, conn: Arc<ConnectionThreadSafe>) -> bool

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

where F: FnOnce(&ConnectionThreadSafe) -> R,

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

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

pub fn cleanup_expired(&self)

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