Struct OperationManager 

pub struct OperationManager<L: Lane> { /* private fields */ }

Implementations

impl<L: Lane> OperationManager<L>

pub async fn register(&self, registration: Registration<L>) -> Result<()>

pub async fn unregister(&self, id: &QualifiedId) -> Result<()>

pub fn with_context(&self, context: CallContext) -> Self

Trait Implementations

impl<L: Clone + Lane> Clone for OperationManager<L>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<L: Lane> Deref for OperationManager<L>

type Target = Manager

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl<L: Lane> Host for OperationManager<L>

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,