Struct QueryTransaction 

pub struct QueryTransaction { /* private fields */ }

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

Implementations

impl QueryTransaction

pub fn new(multi: MultiReadTransaction, single: SingleTransaction) -> Self

Creates a new active query transaction

pub fn version(&self) -> CommitVersion

Get the transaction version

pub fn id(&self) -> TransactionId

Get the transaction ID

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

Get a value by key

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

Check if a key exists

pub fn prefix(&mut self, prefix: &EncodedKey) -> Result<MultiVersionBatch>

Get a prefix batch

pub fn prefix_rev(&mut self, prefix: &EncodedKey) -> Result<MultiVersionBatch>

Get a reverse prefix batch

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

Read as of version exclusive

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

Create a streaming iterator for forward range queries.

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

Create a streaming iterator for reverse range queries.

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

where I: IntoIterator<Item = &'a EncodedKey> + Send, F: FnOnce(&mut SingleReadTransaction<'_>) -> Result<R> + Send, R: Send,

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 MultiReadTransaction) -> Result<R>,

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

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

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

Begin a single-version query transaction for specific keys

Trait Implementations

impl<'a> From<&'a mut QueryTransaction> for Transaction<'a>

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

Converts to this type from the input type.

impl TransactionalDictionaryChanges for QueryTransaction

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

fn find_dictionary_by_name( &self, _namespace: NamespaceId, _name: &str, ) -> Option<&DictionaryDef>

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

fn is_dictionary_deleted_by_name( &self, _namespace: NamespaceId, _name: &str, ) -> bool

impl TransactionalFlowChanges for QueryTransaction

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

fn find_flow_by_name( &self, _namespace: NamespaceId, _name: &str, ) -> Option<&FlowDef>

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

fn is_flow_deleted_by_name(&self, _namespace: NamespaceId, _name: &str) -> bool

impl TransactionalHandlerChanges for QueryTransaction

fn find_handler_by_id(&self, _id: HandlerId) -> Option<&HandlerDef>

fn find_handler_by_name( &self, _namespace: NamespaceId, _name: &str, ) -> Option<&HandlerDef>

fn is_handler_deleted_by_name( &self, _namespace: NamespaceId, _name: &str, ) -> bool

impl TransactionalMigrationChanges for QueryTransaction

fn find_migration(&self, _id: MigrationId) -> Option<&MigrationDef>

fn find_migration_by_name(&self, _name: &str) -> Option<&MigrationDef>

fn is_migration_deleted(&self, _id: MigrationId) -> bool

fn is_migration_deleted_by_name(&self, _name: &str) -> bool

impl TransactionalNamespaceChanges for QueryTransaction

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

fn find_namespace_by_name(&self, _name: &str) -> Option<&Namespace>

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

fn is_namespace_deleted_by_name(&self, _name: &str) -> bool

impl TransactionalPolicyChanges for QueryTransaction

fn find_policy(&self, _id: PolicyId) -> Option<&PolicyDef>

fn find_policy_by_name(&self, _name: &str) -> Option<&PolicyDef>

fn is_policy_deleted(&self, _id: PolicyId) -> bool

fn is_policy_deleted_by_name(&self, _name: &str) -> bool

impl TransactionalProcedureChanges for QueryTransaction

fn find_procedure(&self, _id: ProcedureId) -> Option<&ProcedureDef>

fn find_procedure_by_name( &self, _namespace: NamespaceId, _name: &str, ) -> Option<&ProcedureDef>

fn is_procedure_deleted(&self, _id: ProcedureId) -> bool

fn is_procedure_deleted_by_name( &self, _namespace: NamespaceId, _name: &str, ) -> bool

impl TransactionalRingBufferChanges for QueryTransaction

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

fn find_ringbuffer_by_name( &self, _namespace: NamespaceId, _name: &str, ) -> Option<&RingBufferDef>

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

fn is_ringbuffer_deleted_by_name( &self, _namespace: NamespaceId, _name: &str, ) -> bool

impl TransactionalRoleChanges for QueryTransaction

fn find_role(&self, _id: RoleId) -> Option<&RoleDef>

fn find_role_by_name(&self, _name: &str) -> Option<&RoleDef>

fn is_role_deleted(&self, _id: RoleId) -> bool

fn is_role_deleted_by_name(&self, _name: &str) -> bool

impl TransactionalSeriesChanges for QueryTransaction

fn find_series(&self, _id: SeriesId) -> Option<&SeriesDef>

fn find_series_by_name( &self, _namespace: NamespaceId, _name: &str, ) -> Option<&SeriesDef>

fn is_series_deleted(&self, _id: SeriesId) -> bool

fn is_series_deleted_by_name( &self, _namespace: NamespaceId, _name: &str, ) -> bool

impl TransactionalSubscriptionChanges for QueryTransaction

fn find_subscription(&self, _id: SubscriptionId) -> Option<&SubscriptionDef>

fn is_subscription_deleted(&self, _id: SubscriptionId) -> bool

impl TransactionalSumTypeChanges for QueryTransaction

fn find_sumtype(&self, _id: SumTypeId) -> Option<&SumTypeDef>

fn find_sumtype_by_name( &self, _namespace: NamespaceId, _name: &str, ) -> Option<&SumTypeDef>

fn is_sumtype_deleted(&self, _id: SumTypeId) -> bool

fn is_sumtype_deleted_by_name( &self, _namespace: NamespaceId, _name: &str, ) -> bool

impl TransactionalTableChanges for QueryTransaction

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

fn find_table_by_name( &self, _namespace: NamespaceId, _name: &str, ) -> Option<&TableDef>

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

fn is_table_deleted_by_name(&self, _namespace: NamespaceId, _name: &str) -> bool

impl TransactionalTestChanges for QueryTransaction

fn find_test(&self, _id: TestId) -> Option<&TestDef>

fn find_test_by_name( &self, _namespace: NamespaceId, _name: &str, ) -> Option<&TestDef>

fn is_test_deleted(&self, _id: TestId) -> bool

fn is_test_deleted_by_name(&self, _namespace: NamespaceId, _name: &str) -> bool

impl TransactionalUserAuthenticationChanges for QueryTransaction

fn find_user_authentication( &self, _id: UserAuthenticationId, ) -> Option<&UserAuthenticationDef>

fn find_user_authentication_by_user_and_method( &self, _user_id: UserId, _method: &str, ) -> Option<&UserAuthenticationDef>

fn is_user_authentication_deleted(&self, _id: UserAuthenticationId) -> bool

impl TransactionalUserChanges for QueryTransaction

fn find_user(&self, _id: UserId) -> Option<&UserDef>

fn find_user_by_name(&self, _name: &str) -> Option<&UserDef>

fn is_user_deleted(&self, _id: UserId) -> bool

fn is_user_deleted_by_name(&self, _name: &str) -> bool

impl TransactionalUserRoleChanges for QueryTransaction

fn find_user_role(&self, _user: UserId, _role: RoleId) -> Option<&UserRoleDef>

fn is_user_role_deleted(&self, _user: UserId, _role: RoleId) -> bool

impl TransactionalViewChanges for QueryTransaction

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

fn find_view_by_name( &self, _namespace: NamespaceId, _name: &str, ) -> Option<&ViewDef>

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

fn is_view_deleted_by_name(&self, _namespace: NamespaceId, _name: &str) -> bool

impl TransactionalChanges for QueryTransaction