Crate wrpc_transport

wRPC transport abstractions, codec and framing

wRPC is an RPC framework based on WIT. It follows client-server model, where peers (servers) may serve function and method calls invoked by the other peers (clients).

The two main abstractions on top of which wRPC is built are:

• Invoke - the client-side handle to a wRPC transport, allowing clients to invoke WIT functions over wRPC transport
• Serve - the server-side handle to a wRPC transport, allowing servers to serve WIT functions over wRPC transport

Implementations of Invoke and Serve define transport-specific, multiplexed bidirectional byte stream types:

• Invoke::Incoming and Serve::Incoming represent the stream incoming from a peer.
• Invoke::Outgoing and Serve::Outgoing represent the stream outgoing to a peer.

Re-exports

• pub use frame::Accept;
• pub use frame::Decoder as FrameDecoder;
• pub use frame::Encoder as FrameEncoder;
• pub use frame::Frame;
• pub use frame::FrameRef;
• pub use frame::Server;
• pub use invoke::Invoke;
• pub use invoke::InvokeExt;
• pub use serve::Serve;
• pub use serve::ServeExt;

Modules

• frame
  wRPC transport stream framing
• invoke
  wRPC transport client handle
• serve
  wRPC transport server handle

Structs

• FutureDecoder
  Decoder for future<T>
• FutureEncoder
  Encoder for future<T>
• Incoming
  Buffered incoming stream used for decoding values
• ListDecoder
  Decoder for list<T>
• ListDecoderU8
  Decoder for list<u8>
• ListEncoder
  Encoder for list<T>
• ResourceBorrow
  Borrowed resource handle, represented as an opaque byte blob
• ResourceBorrowDecoder
  Decoder for borrowed resource types
• ResourceEncoder
  Encoder for resource types
• ResourceOwn
  Owned resource handle, represented as an opaque byte blob
• ResourceOwnDecoder
  Decoder for owned resource types
• StreamDecoder
  Decoder for stream<T>
• StreamDecoderBytes
  Decoder for stream<list<u8>>
• StreamDecoderRead
  Decoder for stream<list<u8>> with AsyncRead support
• StreamEncoder
  Encoder for stream<T>
• StreamEncoderBytes
  Encoder for stream<list<u8>>
• StreamEncoderRead
  Encoder for stream<list<u8>> with AsyncRead support
• SyncCodec
  Codec for synchronous values
• UnitCodec
  Codec for ()

Traits

• Decode
  Defines value decoding
• Deferred
  Handles async processing state for codecs
• Encode
  Defines value encoding
• Index
  Multiplexes streams
• SendFuture
  This trait is used as a workaround for compiler bug https://github.com/rust-lang/rust/issues/96865
• TupleDecode
  Marker trait for Decode tuple types
• TupleEncode
  Marker trait for Encode tuple types

Type Aliases

• DeferredFn
  Deferred operation used for async value processing