Struct StandardEngine 

pub struct StandardEngine(/* private fields */);

Implementations

impl StandardEngine

pub fn begin_command(&self, identity: IdentityId) -> Result<CommandTransaction>

pub fn begin_admin(&self, identity: IdentityId) -> Result<AdminTransaction>

pub fn begin_query(&self, identity: IdentityId) -> Result<QueryTransaction>

pub fn clock(&self) -> &Clock

pub fn rng(&self) -> &Rng

pub fn admin_as( &self, identity: IdentityId, rql: &str, params: Params, ) -> ExecutionResult

pub fn command_as( &self, identity: IdentityId, rql: &str, params: Params, ) -> ExecutionResult

pub fn query_as( &self, identity: IdentityId, rql: &str, params: Params, ) -> ExecutionResult

pub fn query_as_at_version( &self, identity: IdentityId, rql: &str, params: Params, lease: &VersionLeaseGuard, ) -> ExecutionResult

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

pub fn subscribe_as( &self, identity: IdentityId, rql: &str, params: Params, ) -> ExecutionResult

pub fn procedure_as( &self, identity: IdentityId, name: &str, params: Params, ) -> ExecutionResult

pub fn register_virtual_table<T: UserVTable>( &self, namespace: &str, name: &str, table: T, ) -> Result<VTableId>

impl StandardEngine

pub fn new( multi: MultiTransaction, single: SingleTransaction, event_bus: EventBus, interceptors: InterceptorFactory, catalog: Catalog, config: EngineConfig, ) -> Self

pub fn create_interceptors(&self) -> Interceptors

pub fn add_interceptor_factory( &self, factory: Arc<dyn Fn(&mut Interceptors) + Send + Sync>, )

pub fn begin_query_at_version( &self, lease: &VersionLeaseGuard, identity: IdentityId, ) -> Result<QueryTransaction>

pub fn acquire_version_lease( &self, version: CommitVersion, ) -> Result<VersionLeaseGuard>

pub fn acquire_current_snapshot_lease( &self, ) -> Result<(CommitVersion, VersionLeaseGuard)>

pub fn multi(&self) -> &MultiTransaction

pub fn multi_owned(&self) -> MultiTransaction

pub fn actor_system(&self) -> ActorSystem

pub fn single(&self) -> &SingleTransaction

pub fn single_owned(&self) -> SingleTransaction

pub fn emit<E: Event>(&self, event: E)

pub fn catalog(&self) -> Catalog

pub fn services(&self) -> Arc<Services>

pub fn flow_operator_store(&self) -> &SystemFlowOperatorStore

pub fn current_version(&self) -> Result<CommitVersion>

pub fn done_until(&self) -> CommitVersion

pub fn query_done_until(&self) -> CommitVersion

pub fn wait_for_mark_timeout( &self, version: CommitVersion, timeout: Duration, ) -> bool

pub fn executor(&self) -> Executor

pub fn ioc(&self) -> &IocContainer

pub fn cdc_store(&self) -> CdcStore

pub fn actor<M: 'static>(&self) -> Option<ActorRef<M>>

where ActorRef<M>: Send + Sync,

pub fn cdc_producer_watermark(&self) -> CommitVersion

pub fn cdc_consumer_watermark(&self) -> CommitVersion

pub fn set_read_only(&self)

pub fn is_read_only(&self) -> bool

pub fn shutdown(&self)

pub fn bulk_insert<'e>( &'e self, identity: IdentityId, ) -> BulkInsertBuilder<'e, Validated>

pub fn bulk_insert_unchecked<'e>( &'e self, identity: IdentityId, ) -> BulkInsertBuilder<'e, Unchecked>

Trait Implementations

impl AuthEngine for StandardEngine

fn begin_admin(&self) -> Result<AdminTransaction>

fn begin_query(&self) -> Result<QueryTransaction>

fn catalog(&self) -> Catalog

impl CdcHost for StandardEngine

fn begin_command(&self) -> Result<CommandTransaction>

fn begin_query(&self) -> Result<QueryTransaction>

fn current_version(&self) -> Result<CommitVersion>

fn done_until(&self) -> CommitVersion

fn wait_for_mark_timeout( &self, version: CommitVersion, timeout: Duration, ) -> bool

fn catalog(&self) -> &Catalog

impl Clone for StandardEngine

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Deref for StandardEngine

type Target = Inner

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl WithEventBus for StandardEngine

fn event_bus(&self) -> &EventBus