Struct CatalogTx 

pub struct CatalogTx { /* private fields */ }

An atomic catalog transaction: an ordered batch of CatalogOps applied together against a CatalogStore.

Examples

let mut tx = CatalogTx::new();
tx.put_row(CatalogRow::new(Symbol::new("registry/libs"), Symbol::new("demo")));
assert_eq!(tx.ops().len(), 1);

Implementations

impl CatalogTx

pub fn new() -> Self

Creates an empty transaction.

pub fn push(&mut self, op: CatalogOp)

Appends one operation to the transaction.

pub fn put_row(&mut self, row: CatalogRow)

Queues a row insert or replace.

pub fn delete_row(&mut self, table: Symbol, key: Symbol)

Queues deletion of the row at table/key.

pub fn bump_sequence(&mut self, name: Symbol, reserved: u64)

Queues reserving reserved ids from the named sequence.

pub fn ops(&self) -> &[CatalogOp]

Returns the queued operations in order.

pub fn validate(&self, store: &CatalogStore) -> Result<()>

Checks the transaction against store without mutating it, enforcing table existence, write policies, required fields, and per-row uniqueness.

pub fn commit(self, store: &mut CatalogStore) -> Result<u64>

Validates and applies the transaction, returning the new catalog epoch and recording an audit event per operation.

Trait Implementations

impl Clone for CatalogTx

fn clone(&self) -> CatalogTx

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CatalogTx

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for CatalogTx

fn default() -> CatalogTx

Returns the “default value” for a type.

impl Eq for CatalogTx

impl PartialEq for CatalogTx

fn eq(&self, other: &CatalogTx) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for CatalogTx