Struct QueryTransaction 

pub struct QueryTransaction {
    pub identity: IdentityId,
    /* private fields */
}

Fields

identity: IdentityId

Implementations

impl QueryTransaction

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

pub fn read_only(multi: MultiReadTransaction, identity: IdentityId) -> Self

pub fn set_executor(&mut self, executor: Arc<dyn RqlExecutor>)

pub fn rql(&mut self, rql: &str, params: Params) -> ExecutionResult

pub fn version(&self) -> CommitVersion

pub fn id(&self) -> TransactionId

pub fn get<K: Into<TaggedKey> + Clone>( &mut self, key: &K, ) -> Result<Option<MultiVersionRow<TaggedKey>>>

pub fn contains<K: Into<TaggedKey> + Clone>(&mut self, key: &K) -> Result<bool>

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

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

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

pub fn range( &self, range: TaggedKeyBoundRange, scope: RangeScope, batch_size: usize, ) -> Box<dyn Iterator<Item = Result<MultiVersionRow<TaggedKey>>> + Send + '_>

pub fn range_row( &self, storage: StorageId, start: Bound<StorageRowKey>, end: Bound<StorageRowKey>, scope: RangeScope, batch_size: usize, ) -> Box<dyn Iterator<Item = Result<MultiVersionRow<StorageRowKey>>> + Send + '_>

pub fn range_partitioned_row( &self, storage: StorageId, start: Bound<StoragePartitionedRowKey>, end: Bound<StoragePartitionedRowKey>, scope: RangeScope, batch_size: usize, ) -> Box<dyn Iterator<Item = Result<MultiVersionRow<StoragePartitionedRowKey>>> + Send + '_>

pub fn range_rev( &self, range: TaggedKeyBoundRange, scope: RangeScope, batch_size: usize, ) -> Box<dyn Iterator<Item = Result<MultiVersionRow<TaggedKey>>> + Send + '_>

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

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

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

fn find_authentication(&self, _id: AuthenticationId) -> Option<&Authentication>

fn find_authentication_by_identity_and_method( &self, _identity: IdentityId, _method: &str, ) -> Option<&Authentication>

fn is_authentication_deleted(&self, _id: AuthenticationId) -> bool

fn is_authentication_deleted_by_identity_and_method( &self, _identity: IdentityId, _method: &str, ) -> bool

impl TransactionalBindingChanges for QueryTransaction

fn find_binding(&self, _id: BindingId) -> Option<&Binding>

fn find_binding_by_name( &self, _namespace: NamespaceId, _name: &str, ) -> Option<&Binding>

fn is_binding_deleted(&self, _id: BindingId) -> bool

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

impl TransactionalChanges for QueryTransaction

impl TransactionalColumnSnapshotChanges for QueryTransaction

fn find_column_snapshot(&self, _id: ColumnSnapshotId) -> Option<&ColumnSnapshot>

fn is_column_snapshot_deleted(&self, _id: ColumnSnapshotId) -> bool

impl TransactionalDictionaryChanges for QueryTransaction

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

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

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<&Flow>

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

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

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

impl TransactionalGrantedRoleChanges for QueryTransaction

fn find_granted_roles_for_identity( &self, _identity: IdentityId, ) -> Vec<&GrantedRole>

fn is_granted_role_deleted(&self, _identity: IdentityId, _role: RoleId) -> bool

impl TransactionalHandlerChanges for QueryTransaction

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

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

fn is_handler_deleted(&self, _id: HandlerId) -> bool

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

impl TransactionalIdentityAttributeChanges for QueryTransaction

fn find_identity_attribute( &self, _id: IdentityAttributeId, ) -> Option<&IdentityAttribute>

fn find_identity_attribute_by_name( &self, _name: &str, ) -> Option<&IdentityAttribute>

fn is_identity_attribute_deleted(&self, _id: IdentityAttributeId) -> bool

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

impl TransactionalIdentityAttributeValueChanges for QueryTransaction

fn find_identity_attribute_value( &self, _identity: IdentityId, _attribute: IdentityAttributeId, ) -> Option<&IdentityAttributeValue>

fn find_identity_attribute_values_for_identity( &self, _identity: IdentityId, ) -> Vec<&IdentityAttributeValue>

fn find_identity_attribute_values_for_attribute( &self, _attribute: IdentityAttributeId, ) -> Vec<&IdentityAttributeValue>

fn is_identity_attribute_value_deleted( &self, _identity: IdentityId, _attribute: IdentityAttributeId, ) -> bool

impl TransactionalIdentityChanges for QueryTransaction

fn find_identity(&self, _id: IdentityId) -> Option<&Identity>

fn find_identity_by_name(&self, _name: &str) -> Option<&Identity>

fn is_identity_deleted(&self, _id: IdentityId) -> bool

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

impl TransactionalMigrationChanges for QueryTransaction

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

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

fn find_operator_settings( &self, _operator: OperatorId, ) -> Option<&OperatorSettings>

impl TransactionalPolicyChanges for QueryTransaction

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

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

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

impl TransactionalProcedureChanges for QueryTransaction

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

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

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

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

impl TransactionalQueueChanges for QueryTransaction

fn find_queue(&self, _id: QueueId) -> Option<&Queue>

fn find_queue_by_name( &self, _namespace: NamespaceId, _name: &str, ) -> Option<&Queue>

fn is_queue_deleted(&self, _id: QueueId) -> bool

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

impl TransactionalRelationshipChanges for QueryTransaction

fn find_relationship(&self, _id: RelationshipId) -> Option<&Relationship>

fn find_relationship_by_name( &self, _namespace: NamespaceId, _source_table: TableId, _name: &str, ) -> Option<&Relationship>

fn is_relationship_deleted(&self, _id: RelationshipId) -> bool

fn is_relationship_deleted_by_name( &self, _namespace: NamespaceId, _source_table: TableId, _name: &str, ) -> bool

impl TransactionalRingBufferChanges for QueryTransaction

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

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

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<&Role>

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

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

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

impl TransactionalRowSettingsChanges for QueryTransaction

fn find_row_settings(&self, _storage: StorageId) -> Option<&RowSettings>

impl TransactionalSeriesChanges for QueryTransaction

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

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

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

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

impl TransactionalSinkChanges for QueryTransaction

fn find_sink(&self, _id: SinkId) -> Option<&Sink>

fn find_sink_by_name( &self, _namespace: NamespaceId, _name: &str, ) -> Option<&Sink>

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

impl TransactionalSourceChanges for QueryTransaction

fn find_source(&self, _id: SourceId) -> Option<&Source>

fn find_source_by_name( &self, _namespace: NamespaceId, _name: &str, ) -> Option<&Source>

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

impl TransactionalSumTypeChanges for QueryTransaction

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

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

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<&Table>

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

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<&Test>

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

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

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

impl TransactionalViewChanges for QueryTransaction

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

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

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

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