Struct ServiceContext 

pub struct ServiceContext<A: Application> { /* private fields */ }

Implementations

impl<A: Application> ServiceContext<A>

pub fn ready(&self)

pub fn host(&self) -> OperationManager<A::Lanes>

pub fn records(&self) -> &RecordManager<A>

pub fn state(&self) -> &StateManager<A>

pub fn streams(&self) -> &StreamManager<A>

pub fn evidence(&self) -> &Evidence<A>

pub fn is_stopping(&self) -> bool

pub async fn stopping(&mut self)

pub async fn rest(&mut self, duration: Duration) -> bool

pub async fn until_stopping<T>( &mut self, future: impl Future<Output = T>, ) -> Option<T>

Trait Implementations

impl<A: Application> Clone for ServiceContext<A>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<A: Application> Host for ServiceContext<A>

type Error = Error

type Instance<O: OperationDeclaration> = Running<O>

fn publish_on<S: StreamSpec>( &self, row: &S::Row, ) -> impl Future<Output = Result<(), Self::Error>> + Send

where S::Row: Message,

fn context(&self) -> &CallContext

fn with_value<T: ContextValue>(&self, value: T) -> Result<Self, ContextError>

fn submit<O: OperationDeclaration>( &self, request: O::Request, ) -> impl Future<Output = Result<Running<O>>> + Send

fn submit_owned<O: OperationDeclaration>( &self, request: O::Request, claims: RequestClaims, ) -> impl Future<Output = Result<Running<O>>> + Send

fn call<O: OperationDeclaration>( &self, request: O::Request, ) -> impl Future<Output = Result<Response<O::Response>>> + Send

fn call_owned<O>( &self, request: <O as OperationDeclaration>::Request, claims: RequestClaims, ) -> impl Future<Output = Result<Response<<O as OperationDeclaration>::Response>, Self::Error>> + Send

where O: OperationDeclaration,

fn publish<S>( &self, row: &S, ) -> impl Future<Output = Result<(), Self::Error>> + Send

where S: StreamSpec<Row = S> + Message,