Struct TxnHandle 

pub struct TxnHandle { /* private fields */ }

Transaction handle for a session.

Implementations

impl TxnHandle

pub fn new(txn: Box<dyn ErasedAsyncSqlTransaction>) -> Self

pub fn created_at(&self) -> SystemTime

pub fn execute<'a>( &'a self, sql: &'a str, ) -> BoxFuture<'a, Result<ExecutionResult>>

pub fn query<'a>(&'a self, sql: &'a str) -> BoxStream<'a, Result<Row>>

pub fn plan_for_routing<'a>( &'a self, sql: &'a str, ) -> BoxFuture<'a, Result<Vec<PlannedStatement>>>

pub async fn buffer_table_lifecycle_effects( &self, effects: Vec<TableLifecycleEffect>, )

pub async fn buffer_catalog_rollback_effects( &self, effects: Vec<CatalogRollbackEffect>, )

pub async fn commit(self) -> Result<Vec<TableLifecycleEffect>>

pub async fn rollback(self) -> Result<Vec<CatalogRollbackEffect>>

Trait Implementations

impl Clone for TxnHandle

fn clone(&self) -> TxnHandle

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.