Struct Services

Source

pub struct Services {
    pub catalog: Catalog,
    pub clock: Clock,
    pub compiler: Compiler,
    pub functions: Functions,
    pub procedures: Procedures,
    pub transforms: Transforms,
    pub flow_operator_store: FlowOperatorStore,
    pub virtual_table_registry: UserVTableRegistry,
    pub stats_reader: MetricReader<SingleStore>,
    pub ioc: IocContainer,
    pub auth_registry: AuthenticationRegistry,
}

Expand description

Services is a container for shared resources used throughout the execution engine.

This struct provides a single location for all the shared resources that the VM, query operators, and other components need access to.

Fields§

§catalog: Catalog§clock: Clock§compiler: Compiler§functions: Functions§procedures: Procedures§transforms: Transforms§flow_operator_store: FlowOperatorStore§virtual_table_registry: UserVTableRegistry§stats_reader: MetricReader<SingleStore>§ioc: IocContainer§auth_registry: AuthenticationRegistry

Services

Struct Services Copy item path

Fields§

Implementations§

impl Services

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 get_handlers( &self, sumtype_id: SumTypeId, variant_tag: u8, ) -> Vec<Box<dyn Procedure>>

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

pub fn testing() -> Arc<Self>

Auto Trait Implementations§

impl Freeze for Services

impl !RefUnwindSafe for Services

impl Send for Services

impl Sync for Services

impl Unpin for Services

impl UnsafeUnpin for Services

impl !UnwindSafe for Services

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

impl<T, U> Into<U> for Twhere U: From<T>,

fn into(self) -> U

impl<T> IntoEither for T

fn into_either(self, into_left: bool) -> Either<Self, Self>

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>where F: FnOnce(&Self) -> bool,

impl<T> Pointable for T

const ALIGN: usize

type Init = T

unsafe fn init(init: <T as Pointable>::Init) -> usize

unsafe fn deref<'a>(ptr: usize) -> &'a T

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

unsafe fn drop(ptr: usize)

impl<T> Same for T

type Output = T

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

type Error = Infallible

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>where S: Into<Dispatch>,

fn with_current_subscriber(self) -> WithDispatch<Self>

Struct Services

impl<T> Any for T
where T: 'static + ?Sized,

impl<T> Borrow<T> for T
where T: ?Sized,

impl<T> BorrowMut<T> for T
where T: ?Sized,

impl<T, U> Into<U> for T
where U: From<T>,

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

impl<T, U> TryFrom<U> for T
where U: Into<T>,

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,