Struct RuntimeTransactionContext 

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

Transaction-scoped façade over RuntimeContext.

This type implements TransactionContext so the runtime can participate in the llkv-transaction engine without exposing transactional methods on the shared RuntimeContext itself. Each instance keeps track of the active snapshot and delegates operations to the underlying context, applying MVCC filtering and conversion of statement results into transaction results.

Trait Implementations

impl<P> CatalogDdl for RuntimeTransactionContext<P>

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

type CreateTableOutput = TransactionResult<P>

Output of executing a CREATE TABLE plan.

type DropTableOutput = ()

Output of executing a DROP TABLE plan.

type RenameTableOutput = ()

Output of executing a table rename.

type AlterTableOutput = TransactionResult<P>

Output of executing an ALTER TABLE plan.

type CreateIndexOutput = TransactionResult<P>

Output of executing a CREATE INDEX plan.

type DropIndexOutput = Option<SingleColumnIndexDescriptor>

Output of executing a DROP INDEX plan.

fn create_table( &self, plan: CreateTablePlan, ) -> LlkvResult<Self::CreateTableOutput>

Creates a table described by the given plan.

fn drop_table(&self, plan: DropTablePlan) -> LlkvResult<Self::DropTableOutput>

Drops a table identified by the given plan.

fn rename_table( &self, plan: RenameTablePlan, ) -> LlkvResult<Self::RenameTableOutput>

Renames a table using the provided plan.

fn alter_table( &self, plan: AlterTablePlan, ) -> LlkvResult<Self::AlterTableOutput>

Alters a table using the provided plan.

fn create_index( &self, plan: CreateIndexPlan, ) -> LlkvResult<Self::CreateIndexOutput>

Creates an index described by the given plan.

fn drop_index(&self, plan: DropIndexPlan) -> LlkvResult<Self::DropIndexOutput>

Drops a single-column index described by the given plan, returning metadata about the index when it existed.

fn create_view(&self, plan: CreateViewPlan) -> LlkvResult<()>

Creates a view described by the given plan.

fn drop_view(&self, plan: DropViewPlan) -> LlkvResult<()>

Drops a view identified by the given plan.

impl<P> TransactionContext for RuntimeTransactionContext<P>

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

type Pager = P

The pager type used by this context

type Snapshot = TableCatalogSnapshot

Snapshot representation returned 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, ) -> LlkvResult<Vec<PlanColumnSpec>>

Get table column specifications

fn export_table_rows(&self, table_name: &str) -> LlkvResult<ExecutorRowBatch>

Export table rows for snapshotting

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

Get batches with row IDs for seeding updates

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

Execute a SELECT plan with this context’s pager type

fn apply_create_table_plan( &self, plan: CreateTablePlan, ) -> LlkvResult<TransactionResult<P>>

Create a table from plan

fn drop_table(&self, plan: DropTablePlan) -> LlkvResult<()>

Drop a table

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

Insert rows

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

Update rows

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

Delete rows

fn truncate(&self, plan: TruncatePlan) -> LlkvResult<TransactionResult<P>>

Truncate table (delete all rows)

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

Create an index

fn append_batches_with_row_ids( &self, table_name: &str, batches: Vec<RecordBatch>, ) -> LlkvResult<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) -> LlkvResult<TableId>

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

fn catalog_snapshot(&self) -> Self::Snapshot

Get an immutable catalog snapshot for transaction isolation

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

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.