Struct Context 

pub struct Context<'a> { /* private fields */ }

Implementations

impl Context<'_>

pub fn context(&self) -> &CallContext

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

pub fn id(&self) -> OperationInstanceId

pub fn attempt(&self) -> usize

pub fn scope(&self) -> &Scope<'_>

pub fn is_host_call(&self) -> bool

pub fn submit_at<O: OperationDeclaration>( &self, id: &str, request: O::Request, ) -> Result<Running<O>>

pub fn submit<O: OperationDeclaration>( &self, request: O::Request, ) -> Result<Running<O>>

pub fn request_claims(&self) -> Option<&RequestClaims>

pub fn submit_owned<O: OperationDeclaration>( &self, request: O::Request, claims: RequestClaims, ) -> Result<Running<O>>

pub fn submit_endpoints<O: OperationDeclaration, P: Send + 'static>( &self, request: O::Request, endpoints: P, ) -> Result<Running<O>>

pub fn submit_charged<O: OperationDeclaration, P: Send + 'static>( &self, request: StreamItem<O::Request>, endpoints: P, ) -> Result<Running<O>>

pub fn submit_caused<O: OperationDeclaration>( &self, request: O::Request, cause: Position, ) -> Result<Running<O>>

pub async fn call_caused<O: OperationDeclaration>( &self, request: O::Request, cause: Position, ) -> Result<Response<O::Response>>

pub async fn call<O: OperationDeclaration>( &self, request: O::Request, ) -> Result<Response<O::Response>>

impl Context<'_>

pub fn upload<O: OperationDeclaration>( &self, request: O::Request, settings: StreamSettings, ) -> Result<Upload<O>>

pub fn download<O: OperationDeclaration>( &self, request: O::Request, settings: StreamSettings, ) -> Result<Download<O>>

pub fn exchange<O: OperationDeclaration>( &self, request: O::Request, input: StreamSettings, output: StreamSettings, ) -> Result<Exchange<O>>

impl Context<'_>

pub fn submit_encoded( &self, operation: &str, payload: Vec<u8>, ) -> Result<EncodedInvocation>

pub async fn call_encoded( &self, operation: &str, payload: Vec<u8>, ) -> Result<Vec<u8>>

Trait Implementations

impl<'a> Clone for Context<'a>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Host for Context<'_>

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,