Enum StandardTransaction 

pub enum StandardTransaction<'a> {
    Command(&'a mut StandardCommandTransaction),
    Query(&'a mut StandardQueryTransaction),
}

An enum that can hold either a command or query transaction for flexible execution

Variants

Command(&'a mut StandardCommandTransaction)

Query(&'a mut StandardQueryTransaction)

Implementations

impl<'a> StandardTransaction<'a>

pub fn command(self) -> &'a mut StandardCommandTransaction

Extract the underlying StandardCommandTransaction, panics if this is a Query transaction

pub fn query(self) -> &'a mut StandardQueryTransaction

Extract the underlying StandardQueryTransaction, panics if this is a Command transaction

pub fn command_mut(&mut self) -> &mut StandardCommandTransaction

Get a mutable reference to the underlying StandardCommandTransaction, panics if this is a Query transaction

pub fn query_mut(&mut self) -> &mut StandardQueryTransaction

Get a mutable reference to the underlying StandardQueryTransaction, panics if this is a Command transaction

pub fn catalog(&self) -> &MaterializedCatalog

pub fn version(&self) -> CommitVersion

Trait Implementations

impl<'a> From<&'a mut StandardCommandTransaction> for StandardTransaction<'a>

fn from(txn: &'a mut StandardCommandTransaction) -> Self

Converts to this type from the input type.

impl<'a> From<&'a mut StandardQueryTransaction> for StandardTransaction<'a>

fn from(txn: &'a mut StandardQueryTransaction) -> Self

Converts to this type from the input type.

impl<'a> MultiVersionQueryTransaction for StandardTransaction<'a>

fn version(&self) -> CommitVersion

fn id(&self) -> TransactionId

fn get(&mut self, key: &EncodedKey) -> Result<Option<MultiVersionValues>>

fn contains_key(&mut self, key: &EncodedKey) -> Result<bool>

fn range_batched( &mut self, range: EncodedKeyRange, batch_size: u64, ) -> Result<BoxedMultiVersionIter<'_>>

fn range_rev_batched( &mut self, range: EncodedKeyRange, batch_size: u64, ) -> Result<BoxedMultiVersionIter<'_>>

fn prefix(&mut self, prefix: &EncodedKey) -> Result<BoxedMultiVersionIter<'_>>

fn prefix_rev( &mut self, prefix: &EncodedKey, ) -> Result<BoxedMultiVersionIter<'_>>

fn read_as_of_version_exclusive(&mut self, version: CommitVersion) -> Result<()>

fn range( &mut self, range: EncodedKeyRange, ) -> Result<Box<dyn Iterator<Item = MultiVersionValues> + Send + '_>, Error>

fn range_rev( &mut self, range: EncodedKeyRange, ) -> Result<Box<dyn Iterator<Item = MultiVersionValues> + Send + '_>, Error>

fn read_as_of_version_inclusive( &mut self, version: CommitVersion, ) -> Result<(), Error>

impl<'a> QueryTransaction for StandardTransaction<'a>

type SingleVersionQuery<'b> = <TransactionSingleVersion as SingleVersionTransaction>::Query<'b> where Self: 'b

type CdcQuery<'b> = <TransactionCdc as CdcTransaction>::Query<'b> where Self: 'b

fn begin_single_query<'k, I>( &self, keys: I, ) -> Result<Self::SingleVersionQuery<'_>>

where I: IntoIterator<Item = &'k EncodedKey>,

fn begin_cdc_query(&self) -> Result<Self::CdcQuery<'_>>

fn with_single_query<'a, I, F, R>(&self, keys: I, f: F) -> Result<R, Error>

where I: IntoIterator<Item = &'a EncodedKey>, F: FnOnce(&mut Self::SingleVersionQuery<'_>) -> Result<R, Error>,

fn with_cdc_query<F, R>(&self, f: F) -> Result<R, Error>

where F: FnOnce(&mut Self::CdcQuery<'_>) -> Result<R, Error>,