Struct TestEngine 

pub struct TestEngine { /* private fields */ }

Implementations

impl TestEngine

pub fn new() -> Self

pub fn builder() -> TestEngineBuilder

pub fn admin(&self, rql: &str) -> Vec<Frame>

pub fn command(&self, rql: &str) -> Vec<Frame>

pub fn query(&self, rql: &str) -> Vec<Frame>

pub fn admin_err(&self, rql: &str) -> String

pub fn command_err(&self, rql: &str) -> String

pub fn query_err(&self, rql: &str) -> String

pub fn row_count(frames: &[Frame]) -> usize

pub fn identity() -> IdentityId

pub fn inner(&self) -> &StandardEngine

pub fn mock_clock(&self) -> MockClock

Methods from Deref<Target = 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>

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 Default for TestEngine

fn default() -> Self

Returns the “default value” for a type.

impl Deref for TestEngine

type Target = StandardEngine

The resulting type after dereferencing.

fn deref(&self) -> &StandardEngine

Dereferences the value.