Struct StandardEngine 

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

Implementations

impl StandardEngine

pub fn new( multi: TransactionMultiVersion, single: TransactionSingleVersion, cdc: TransactionCdc, event_bus: EventBus, interceptors: Box<dyn InterceptorFactory<StandardCommandTransaction>>, catalog: MaterializedCatalog, ) -> Self

pub fn with_functions( multi: TransactionMultiVersion, single: TransactionSingleVersion, cdc: TransactionCdc, event_bus: EventBus, interceptors: Box<dyn InterceptorFactory<StandardCommandTransaction>>, catalog: MaterializedCatalog, custom_functions: Option<Functions>, ) -> Self

pub fn multi(&self) -> &TransactionMultiVersion

pub fn multi_owned(&self) -> TransactionMultiVersion

pub fn single(&self) -> &TransactionSingleVersion

pub fn single_owned(&self) -> TransactionSingleVersion

pub fn cdc(&self) -> &TransactionCdc

pub fn cdc_owned(&self) -> TransactionCdc

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

pub fn catalog(&self) -> &MaterializedCatalog

pub fn flow_operator_store(&self) -> &FlowOperatorStore

pub fn executor(&self) -> Executor

Trait Implementations

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 = EngineInner

The resulting type after dereferencing.

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

Dereferences the value.

impl Engine for StandardEngine

type Command = StandardCommandTransaction

type Query = StandardQueryTransaction

fn begin_command(&self) -> Result<Self::Command>

fn begin_query(&self) -> Result<Self::Query>

fn command_as( &self, identity: &Identity, rql: &str, params: Params, ) -> Result<Vec<Frame>>

fn query_as( &self, identity: &Identity, rql: &str, params: Params, ) -> Result<Vec<Frame>>

impl ExecuteCommand<StandardCommandTransaction> for StandardEngine

fn execute_command( &self, txn: &mut StandardCommandTransaction, cmd: Command<'_>, ) -> Result<Vec<Frame>>

impl ExecuteQuery<StandardQueryTransaction> for StandardEngine

fn execute_query( &self, txn: &mut StandardQueryTransaction, qry: Query<'_>, ) -> Result<Vec<Frame>>

impl WithEventBus for StandardEngine

fn event_bus(&self) -> &EventBus