Struct WireTable 

pub struct WireTable { /* private fields */ }

Implementations

impl WireTable

pub fn install_lifecycle<D, T>( &mut self, dependencies: Dependencies, descriptor: Descriptor, ) -> Result<(), ServingError>

where D: OperationDeclaration, T: Carrier<Declaration = D, StreamEndpoints = ()>,

impl WireTable

pub fn new(owner: &str) -> Result<Self, ServingError>

pub fn provide(&mut self, resource: TypeId)

pub fn provided(&self) -> &[TypeId]

pub fn capacity(&mut self, capacity: NonZeroUsize)

pub fn register(&mut self, batch: RegistrationBatch) -> Result<(), ServingError>

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

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

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

pub fn validate_callees(&self, assignments: &[u8]) -> Result<(), ServingError>

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

pub fn prepare( &mut self, invocation: u64, operation: &str, fingerprint: [u8; 32], generation: u64, payload: Vec<u8>, ) -> Result<Vec<u8>, ServingError>

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

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

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

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

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

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

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

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

pub fn release(&mut self) -> Result<impl Send + use<>, 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: &ExecutionContext, ) -> WireAnswer