Struct WireTable 

pub struct WireTable<C> { /* private fields */ }

Implementations

impl<C> WireTable<C>

where C: Send + Sync + 'static,

pub fn bind_operation<T>( &mut self, resources: Arc<<T as Operation>::Resources>, ) -> Result<(), ServingError>

where T: for<'a> Operation<Context<'a> = &'a C, Endpoints = ()>,

pub fn bind_resident_operation<T>( &mut self, resources: Arc<<T as Operation>::Resources>, ) -> Result<(), ServingError>

where T: for<'a> Operation<Context<'a> = &'a C, Endpoints = ()>,

pub fn bind_observe_control<T>( &mut self, resources: Arc<<T as Operation>::Resources>, ) -> Result<(), ServingError>

where T: for<'a> Operation<Context<'a> = &'a C, Endpoints = (), Declaration = Control>,

pub fn bind_streaming_operation<T>( &mut self, resources: Arc<<T as Operation>::Resources>, limits: WireStreamLimits, ) -> Result<(), ServingError>

where T: for<'a> Operation<Context<'a> = &'a C>, <T as Operation>::Endpoints: WireEndpoints,

impl<C> WireTable<C>

where C: Send + Sync + 'static,

pub fn new(capacity: NonZero<usize>) -> WireTable<C>

pub fn of<T, R>( resources: Arc<R>, capacity: NonZero<usize>, ) -> Result<WireTable<C>, ServingError>

where T: Catalog<AuthoredDeclarations> + Catalog<Serves<R, C>>, R: Send + Sync + 'static,

pub fn bind_operations<T, R>( &mut self, resources: Arc<R>, ) -> Result<(), ServingError>

where T: Catalog<AuthoredDeclarations> + Catalog<Serves<R, C>>, R: Send + Sync + 'static,

pub fn bind_streaming_operations<T, R>( &mut self, resources: Arc<R>, limits: WireStreamLimits, ) -> Result<(), ServingError>

where T: Catalog<AuthoredDeclarations> + Catalog<Serves<R, C>>, R: Send + Sync + 'static,

pub fn definitions(&self) -> Vec<Definition>

pub fn validate(&self, definitions: &[Definition]) -> Result<(), ServingError>

pub fn validate_contracts( &self, contracts: &[Contract], ) -> Result<(), ServingError>

pub fn prepare( &mut self, invocation: u64, operation: &str, payload: Vec<u8>, ) -> Result<Vec<u8>, ServingError>

pub fn streams(&self, invocation: u64) -> Result<WireStreams, ServingError>

pub async fn initialize( &mut self, invocation: u64, context: &C, ) -> Result<(), ServingError>

pub async fn attempt( &mut self, invocation: u64, context: &C, ) -> Result<Vec<u8>, ServingError>

pub async fn finalize(&mut self, invocation: u64) -> Result<(), ServingError>

pub fn begin( &mut self, command: WireCommand, context: Arc<C>, ) -> Pin<Box<dyn Future<Output = WireAnswer> + Send>>

pub fn close_ordinary( &mut self, ) -> Pin<Box<dyn Future<Output = Result<(), ServingError>> + Send>>

pub fn release_ordinary(&mut self) -> Result<impl Send + use<C>, ServingError>

pub async fn settle_ordinary(&mut self) -> Result<(), ServingError>

pub fn close( &mut self, ) -> Pin<Box<dyn Future<Output = Result<(), ServingError>> + Send>>

pub fn release(&mut self) -> Result<impl Send + use<C>, ServingError>

pub async fn settle(&mut self) -> Result<(), ServingError>

pub fn is_settled(&self) -> bool

pub fn is_closed(&self) -> bool

pub async fn answer(&mut self, command: WireCommand, context: &C) -> WireAnswer