Struct Executor 

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

Executor is the orchestration layer for RQL statement execution.

Implementations

impl Executor

pub fn new( catalog: Catalog, config: EngineConfig, flow_operator_store: SystemFlowOperatorStore, stats_reader: MetricReader<SingleStore>, ) -> Self

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

Get a reference to the underlying Services

pub fn from_services(services: Arc<Services>) -> Self

Construct an Executor from an existing Arc<Services>.

pub fn testing() -> Self

impl Executor

pub fn rql( &self, tx: &mut Transaction<'_>, rql: &str, params: Params, ) -> ExecutionResult

Execute RQL against an existing open transaction.

This is the universal RQL execution interface: it compiles and runs arbitrary RQL within whatever transaction variant the caller provides.

pub fn admin( &self, txn: &mut AdminTransaction, cmd: Admin<'_>, ) -> ExecutionResult

pub fn test( &self, txn: &mut TestTransaction<'_>, cmd: Test<'_>, ) -> ExecutionResult

pub fn subscription( &self, txn: &mut QueryTransaction, cmd: Subscription<'_>, ) -> ExecutionResult

pub fn command( &self, txn: &mut CommandTransaction, cmd: Command<'_>, ) -> ExecutionResult

pub fn call_procedure( &self, txn: &mut CommandTransaction, name: &str, params: &Params, ) -> ExecutionResult

Call a procedure by fully-qualified name (e.g., “banking.transfer_funds”).

pub fn query( &self, txn: &mut QueryTransaction, qry: Query<'_>, ) -> ExecutionResult

Methods from Deref<Target = Services>

pub fn get_handlers(&self, variant: VariantRef) -> Vec<Box<dyn Procedure>>

pub fn get_procedure(&self, name: &str) -> Option<Box<dyn Procedure>>

Trait Implementations

impl Clone for Executor

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 Executor

type Target = Services

The resulting type after dereferencing.

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

Dereferences the value.

impl RqlExecutor for Executor

fn rql( &self, tx: &mut Transaction<'_>, rql: &str, params: Params, ) -> ExecutionResult