Struct Executor 

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

Executor is the orchestration layer for RQL statement execution.

Implementations

impl Executor

pub fn new( catalog: Catalog, clock: Clock, functions: Functions, procedures: Procedures, transforms: Transforms, flow_operator_store: FlowOperatorStore, stats_reader: MetricReader<SingleStore>, ioc: IocContainer, ) -> 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<'_>, identity: IdentityId, rql: &str, params: Params, ) -> Result<Vec<Frame>>

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<'_>, ) -> Result<Vec<Frame>>

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

pub fn call_procedure( &self, txn: &mut CommandTransaction, identity: IdentityId, name: &str, params: &Params, ) -> Result<Vec<Frame>>

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

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

Methods from Deref<Target = Services>

pub fn get_handlers( &self, sumtype_id: SumTypeId, variant_tag: u8, ) -> 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.