Struct RuntimeContextWrapper 

pub struct RuntimeContextWrapper<P>
where
    P: Pager<Blob = EntryHandle> + Send + Sync,
{ /* private fields */ }

Wrapper for Context that implements TransactionContext

Trait Implementations

impl<P> TransactionContext for RuntimeContextWrapper<P>

where P: Pager<Blob = EntryHandle> + Send + Sync + 'static,

type Pager = P

The pager type used by this context

fn set_snapshot(&self, snapshot: TransactionSnapshot)

Update the snapshot used for MVCC visibility decisions.

fn snapshot(&self) -> TransactionSnapshot

Get the snapshot currently associated with this context.

fn table_column_specs(&self, table_name: &str) -> Result<Vec<ColumnSpec>>

Get table column specifications

fn export_table_rows(&self, table_name: &str) -> Result<RowBatch>

Export table rows for snapshotting

fn get_batches_with_row_ids( &self, table_name: &str, filter: Option<LlkvExpr<'static, String>>, ) -> Result<Vec<RecordBatch>>

Get batches with row IDs for seeding updates

fn execute_select( &self, plan: SelectPlan, ) -> Result<SelectExecution<Self::Pager>>

Execute a SELECT plan with this context’s pager type

fn create_table_plan( &self, plan: CreateTablePlan, ) -> Result<TransactionResult<P>>

Create a table from plan

fn insert(&self, plan: InsertPlan) -> Result<TransactionResult<P>>

Insert rows

fn update(&self, plan: UpdatePlan) -> Result<TransactionResult<P>>

Update rows

fn delete(&self, plan: DeletePlan) -> Result<TransactionResult<P>>

Delete rows

fn create_index(&self, plan: CreateIndexPlan) -> Result<TransactionResult<P>>

Create an index

fn append_batches_with_row_ids( &self, table_name: &str, batches: Vec<RecordBatch>, ) -> Result<usize>

Append batches with row IDs

fn table_names(&self) -> Vec<String>

Get table names for catalog snapshot

fn table_id(&self, table_name: &str) -> Result<TableId>

Get table ID for a given table name (for conflict detection)

fn catalog_snapshot(&self) -> TableCatalogSnapshot

Get an immutable catalog snapshot for transaction isolation

fn validate_commit_constraints(&self, txn_id: TxnId) -> Result<()>

Validate any pending commit-time constraints for this transaction.

fn clear_transaction_state(&self, txn_id: TxnId)

Clear any transaction-scoped state retained by the context.