Struct AdminTransaction

Source

pub struct AdminTransaction {
    pub multi: MultiTransaction,
    pub single: SingleTransaction,
    pub cmd: Option<MultiWriteTransaction>,
    pub event_bus: EventBus,
    pub changes: TransactionalCatalogChanges,
    pub interceptors: Interceptors,
    pub identity: IdentityId,
    /* private fields */
}

Expand description

An active admin transaction that supports Query + DML + DDL operations.

AdminTransaction is the most privileged transaction type, capable of executing DDL (shape changes), DML (data mutations), and queries. It tracks catalog definition changes (TransactionalCatalogChanges) for DDL.

The transaction will auto-rollback on drop if not explicitly committed.

Fields§

§multi: MultiTransaction§single: SingleTransaction§cmd: Option<MultiWriteTransaction>§event_bus: EventBus§changes: TransactionalCatalogChanges§interceptors: Interceptors§identity: IdentityId

The identity executing this transaction.

Struct AdminTransaction Copy item path

Fields§

Implementations§

impl AdminTransaction

pub fn new( multi: MultiTransaction, single: SingleTransaction, event_bus: EventBus, interceptors: Interceptors, identity: IdentityId, clock: Clock, ) -> Result<Self>

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

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

pub fn event_bus(&self) -> &EventBus

pub fn commit(&mut self) -> Result<CommitVersion>

pub fn rollback(&mut self) -> Result<()>

pub fn pending_writes(&self) -> &PendingWrites

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,

pub fn with_single_command<'a, I, F, R>(&self, keys: I, f: F) -> Result<R>where I: IntoIterator<Item = &'a EncodedKey> + Send, F: FnOnce(&mut SingleWriteTransaction<'_>) -> Result<R> + Send, R: Send,

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

pub fn with_multi_query_as_of_exclusive<F, R>( &self, version: CommitVersion, f: F, ) -> Result<R>where F: FnOnce(&mut QueryTransaction) -> Result<R>,

pub fn with_multi_query_as_of_inclusive<F, R>( &self, version: CommitVersion, f: F, ) -> Result<R>where F: FnOnce(&mut QueryTransaction) -> Result<R>,

pub fn begin_single_query<'a, I>( &self, keys: I, ) -> Result<SingleReadTransaction<'_>>where I: IntoIterator<Item = &'a EncodedKey>,

pub fn begin_single_command<'a, I>( &self, keys: I, ) -> Result<SingleWriteTransaction<'_>>where I: IntoIterator<Item = &'a EncodedKey>,

pub fn get_changes(&self) -> &TransactionalCatalogChanges

pub fn track_row_change(&mut self, change: RowChange)

pub fn track_flow_change(&mut self, change: Change)

pub fn version(&self) -> CommitVersion

pub fn id(&self) -> TransactionId

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

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

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

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

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

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

pub fn set(&mut self, key: &EncodedKey, row: EncodedRow) -> Result<()>

pub fn unset(&mut self, key: &EncodedKey, row: EncodedRow) -> Result<()>

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

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

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

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

Trait Implementations§

impl CatalogTrackAuthenticationChangeOperations for AdminTransaction

fn track_authentication_created(&mut self, auth: Authentication) -> Result<()>

fn track_authentication_deleted(&mut self, auth: Authentication) -> Result<()>

impl CatalogTrackBindingChangeOperations for AdminTransaction

fn track_binding_created(&mut self, binding: Binding) -> Result<()>

fn track_binding_deleted(&mut self, binding: Binding) -> Result<()>

impl CatalogTrackConfigChangeOperations for AdminTransaction

fn track_config_set(&mut self, pre: Config, post: Config) -> Result<()>

impl CatalogTrackDictionaryChangeOperations for AdminTransaction

fn track_dictionary_created(&mut self, dictionary: Dictionary) -> Result<()>

fn track_dictionary_updated( &mut self, pre: Dictionary, post: Dictionary, ) -> Result<()>

fn track_dictionary_deleted(&mut self, dictionary: Dictionary) -> Result<()>

impl CatalogTrackFlowChangeOperations for AdminTransaction

fn track_flow_created(&mut self, flow: Flow) -> Result<()>

fn track_flow_updated(&mut self, pre: Flow, post: Flow) -> Result<()>

fn track_flow_deleted(&mut self, flow: Flow) -> Result<()>

impl CatalogTrackGrantedRoleChangeOperations for AdminTransaction

fn track_granted_role_created( &mut self, granted_role: GrantedRole, ) -> Result<()>

fn track_granted_role_deleted( &mut self, granted_role: GrantedRole, ) -> Result<()>

impl CatalogTrackHandlerChangeOperations for AdminTransaction

fn track_handler_created(&mut self, handler: Handler) -> Result<()>

fn track_handler_deleted(&mut self, handler: Handler) -> Result<()>

impl CatalogTrackIdentityChangeOperations for AdminTransaction

fn track_identity_created(&mut self, identity: Identity) -> Result<()>

fn track_identity_updated( &mut self, pre: Identity, post: Identity, ) -> Result<()>

fn track_identity_deleted(&mut self, identity: Identity) -> Result<()>

impl CatalogTrackMigrationChangeOperations for AdminTransaction

fn track_migration_created(&mut self, migration: Migration) -> Result<()>

fn track_migration_deleted(&mut self, migration: Migration) -> Result<()>

impl CatalogTrackMigrationEventChangeOperations for AdminTransaction

fn track_migration_event_created(&mut self, event: MigrationEvent) -> Result<()>

impl CatalogTrackNamespaceChangeOperations for AdminTransaction

fn track_namespace_created(&mut self, namespace: Namespace) -> Result<()>

fn track_namespace_updated( &mut self, pre: Namespace, post: Namespace, ) -> Result<()>

fn track_namespace_deleted(&mut self, namespace: Namespace) -> Result<()>

impl CatalogTrackPolicyChangeOperations for AdminTransaction

fn track_policy_created(&mut self, policy: Policy) -> Result<()>

fn track_policy_updated(&mut self, pre: Policy, post: Policy) -> Result<()>

fn track_policy_deleted(&mut self, policy: Policy) -> Result<()>

impl CatalogTrackProcedureChangeOperations for AdminTransaction

fn track_procedure_created(&mut self, procedure: Procedure) -> Result<()>

fn track_procedure_updated( &mut self, pre: Procedure, post: Procedure, ) -> Result<()>

fn track_procedure_deleted(&mut self, procedure: Procedure) -> Result<()>

impl CatalogTrackRingBufferChangeOperations for AdminTransaction

Struct AdminTransaction

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,

pub fn with_single_command<'a, I, F, R>(&self, keys: I, f: F) -> Result<R>
where I: IntoIterator<Item = &'a EncodedKey> + Send, F: FnOnce(&mut SingleWriteTransaction<'_>) -> Result<R> + Send, R: Send,

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

pub fn with_multi_query_as_of_exclusive<F, R>( &self, version: CommitVersion, f: F, ) -> Result<R>
where F: FnOnce(&mut QueryTransaction) -> Result<R>,

pub fn with_multi_query_as_of_inclusive<F, R>( &self, version: CommitVersion, f: F, ) -> Result<R>
where F: FnOnce(&mut QueryTransaction) -> Result<R>,

pub fn begin_single_query<'a, I>( &self, keys: I, ) -> Result<SingleReadTransaction<'_>>
where I: IntoIterator<Item = &'a EncodedKey>,

pub fn begin_single_command<'a, I>( &self, keys: I, ) -> Result<SingleWriteTransaction<'_>>
where I: IntoIterator<Item = &'a EncodedKey>,