Struct RuntimeTransaction 

pub struct RuntimeTransaction { /* private fields */ }

Open TypeDB transaction owned by the shared runtime.

Implementations

impl RuntimeTransaction

pub fn supports_given_rows(&self) -> bool

Return whether this transaction’s negotiated driver can transport given input rows.

pub fn query(&mut self, typeql: &str) -> BoxFuture<'_, Result<QueryResult>>

Execute TypeQL within this transaction, materializing for legacy callers.

New match executors use Self::query_bounded directly.

pub fn query_bounded<'a>( &'a mut self, typeql: &'a str, limits: RuntimeAnswerLimits, consumer: &'a mut (dyn FnMut(RuntimeAnswerItem) -> Result<RuntimeAnswerControl> + Send), ) -> BoxFuture<'a, Result<RuntimeAnswerStats>>

Execute TypeQL and enforce bounds while polling the driver stream.

pub fn query_v2_bounded<'a>( &'a mut self, typeql: &'a str, limits: QueryV2RuntimeAnswerLimits, consumer: &'a mut (dyn FnMut(RuntimeAnswerItem) -> Result<RuntimeAnswerControl> + Send), ) -> BoxFuture<'a, Result<RuntimeAnswerStats>>

Execute V2 TypeQL with an additive document collection-member limit.

pub fn query_with_rows( &mut self, typeql: &str, rows: GivenRowsSpec, ) -> BoxFuture<'_, Result<QueryResult>>

Execute TypeQL with given-stage input rows within this transaction.

Rows travel through the driver API, not the query string, so this path is only available on the band-9 (TypeDB 3.12+) driver. On a band-8 connection this returns an actionable error — callers that can fall back to per-row queries should consult the detected server version before choosing this path.

pub fn query_with_rows_bounded<'a>( &'a mut self, typeql: &'a str, rows: GivenRowsSpec, limits: RuntimeAnswerLimits, consumer: &'a mut (dyn FnMut(RuntimeAnswerItem) -> Result<RuntimeAnswerControl> + Send), ) -> BoxFuture<'a, Result<RuntimeAnswerStats>>

Execute TypeQL with given rows and enforce bounds while polling the driver answer stream.

pub fn query_v2_with_rows_bounded<'a>( &'a mut self, typeql: &'a str, rows: GivenRowsSpec, limits: QueryV2RuntimeAnswerLimits, consumer: &'a mut (dyn FnMut(RuntimeAnswerItem) -> Result<RuntimeAnswerControl> + Send), ) -> BoxFuture<'a, Result<RuntimeAnswerStats>>

Execute a V2 given query with an additive collection-member limit.

pub fn commit(&mut self) -> BoxFuture<'_, Result<()>>

Commit this transaction.

pub fn commit_classified( &mut self, ) -> BoxFuture<'_, Result<(), RuntimeCommitError>>

Commit this transaction while retaining driver durability certainty.

pub fn rollback(&mut self) -> BoxFuture<'_, Result<()>>

Roll back this transaction.

pub fn close(&mut self) -> BoxFuture<'_, Result<()>>

Close this transaction without committing.

Trait Implementations

impl Drop for RuntimeTransaction

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.