Struct StandardQueryTransaction 

pub struct StandardQueryTransaction { /* private fields */ }

An active query transaction that holds a multi query transaction and provides query-only access to single storage.

Implementations

impl StandardQueryTransaction

pub fn new( multi: <TransactionMultiVersion as MultiVersionTransaction>::Query, single: TransactionSingleVersion, cdc: TransactionCdc, catalog: MaterializedCatalog, ) -> Self

Creates a new active query transaction

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

where I: IntoIterator<Item = &'a EncodedKey>, F: FnOnce(&mut <TransactionSingleVersion as SingleVersionTransaction>::Query<'_>) -> Result<R>,

Execute a function with query access to the single transaction.

pub fn with_multi_query<F, R>(&mut self, f: F) -> Result<R>

where F: FnOnce(&mut <TransactionMultiVersion as MultiVersionTransaction>::Query) -> Result<R>,

Execute a function with access to the multi query transaction. This operates within the same transaction context.

pub fn cdc(&self) -> &TransactionCdc

Get access to the CDC transaction interface

Trait Implementations

impl ExecuteQuery<StandardQueryTransaction> for Executor

fn execute_query( &self, txn: &mut StandardQueryTransaction, qry: Query<'_>, ) -> Result<Vec<Frame>>

impl ExecuteQuery<StandardQueryTransaction> for StandardEngine

fn execute_query( &self, txn: &mut StandardQueryTransaction, qry: Query<'_>, ) -> Result<Vec<Frame>>

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 MaterializedCatalogTransaction for StandardQueryTransaction

fn catalog(&self) -> &MaterializedCatalog

impl MultiVersionQueryTransaction for StandardQueryTransaction

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 QueryTransaction for StandardQueryTransaction

type SingleVersionQuery<'a> = <TransactionSingleVersion as SingleVersionTransaction>::Query<'a>

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

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

where I: IntoIterator<Item = &'a 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>,

impl TransactionalDictionaryChanges for StandardQueryTransaction

fn find_dictionary(&self, _id: DictionaryId) -> Option<&DictionaryDef>

fn find_dictionary_by_name<'a>( &self, _namespace: NamespaceId, _name: impl IntoFragment<'a>, ) -> Option<&DictionaryDef>

fn is_dictionary_deleted(&self, _id: DictionaryId) -> bool

fn is_dictionary_deleted_by_name<'a>( &self, _namespace: NamespaceId, _name: impl IntoFragment<'a>, ) -> bool

impl TransactionalFlowChanges for StandardQueryTransaction

fn find_flow(&self, _id: FlowId) -> Option<&FlowDef>

fn find_flow_by_name<'a>( &self, _namespace: NamespaceId, _name: impl IntoFragment<'a>, ) -> Option<&FlowDef>

fn is_flow_deleted(&self, _id: FlowId) -> bool

fn is_flow_deleted_by_name<'a>( &self, _namespace: NamespaceId, _name: impl IntoFragment<'a>, ) -> bool

impl TransactionalNamespaceChanges for StandardQueryTransaction

fn find_namespace(&self, _id: NamespaceId) -> Option<&NamespaceDef>

fn find_namespace_by_name<'a>( &self, _name: impl IntoFragment<'a>, ) -> Option<&NamespaceDef>

fn is_namespace_deleted(&self, _id: NamespaceId) -> bool

fn is_namespace_deleted_by_name<'a>(&self, _name: impl IntoFragment<'a>) -> bool

impl TransactionalRingBufferChanges for StandardQueryTransaction

fn find_ring_buffer(&self, _id: RingBufferId) -> Option<&RingBufferDef>

fn find_ring_buffer_by_name<'a>( &self, _namespace: NamespaceId, _name: impl IntoFragment<'a>, ) -> Option<&RingBufferDef>

fn is_ring_buffer_deleted(&self, _id: RingBufferId) -> bool

fn is_ring_buffer_deleted_by_name<'a>( &self, _namespace: NamespaceId, _name: impl IntoFragment<'a>, ) -> bool

impl TransactionalTableChanges for StandardQueryTransaction

fn find_table(&self, _id: TableId) -> Option<&TableDef>

fn find_table_by_name<'a>( &self, _namespace: NamespaceId, _name: impl IntoFragment<'a>, ) -> Option<&TableDef>

fn is_table_deleted(&self, _id: TableId) -> bool

fn is_table_deleted_by_name<'a>( &self, _namespace: NamespaceId, _name: impl IntoFragment<'a>, ) -> bool

impl TransactionalViewChanges for StandardQueryTransaction

fn find_view(&self, _id: ViewId) -> Option<&ViewDef>

fn find_view_by_name<'a>( &self, _namespace: NamespaceId, _name: impl IntoFragment<'a>, ) -> Option<&ViewDef>

fn is_view_deleted(&self, _id: ViewId) -> bool

fn is_view_deleted_by_name<'a>( &self, _namespace: NamespaceId, _name: impl IntoFragment<'a>, ) -> bool

impl Execute<StandardCommandTransaction, StandardQueryTransaction> for Executor

impl TransactionalChanges for StandardQueryTransaction