Struct HostContext 

pub struct HostContext { /* private fields */ }

Implementations

impl HostContext

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

pub fn borrow(&self) -> Context<'_>

Trait Implementations

impl Caller for HostContext

fn call(&self, target: Target, request: Box<dyn Any + Send>) -> CallFuture<'_>

impl Clone for HostContext

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Discovery for HostContext

fn discover( &self, after: Option<&str>, rows: usize, bytes: usize, ) -> Result<DiscoveryPage, AccessError>

impl GrantAuthority for HostContext

fn admit(&self, grant: &Grant) -> Result<(), AccessError>

impl Host for HostContext

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>

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

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

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

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,

impl Instances for HostContext

fn owned(&self, id: OperationInstanceId) -> Option<Arc<dyn InstanceControl>>