starpc 0.49.6

Streaming protobuf RPC framework
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39

//! RpcStream module for nested RPC calls.
//!
//! This module enables nesting RPC calls within RPC calls, supporting
//! component-based architectures where different components expose different
//! services via sub-streams.
//!
//! # Overview
//!
//! The rpcstream protocol works as follows:
//! 1. Client opens a bidirectional stream to the server
//! 2. Client sends `RpcStreamInit` with the target component ID
//! 3. Server looks up the component and sends `RpcAck`
//! 4. Both sides exchange `RpcStreamPacket::Data` containing nested RPC packets
//!
//! # Example
//!
//! ```rust,ignore
//! use starpc::rpcstream::{open_rpc_stream, RpcStreamGetter};
//!
//! // Client side: open a stream to a component
//! let stream = my_service.rpc_stream().await?;
//! let rpc_stream = open_rpc_stream(stream, "my-component", true).await?;
//!
//! // Server side: handle incoming rpc stream
//! let getter: RpcStreamGetter = Arc::new(|ctx, component_id, released| {
//!     // Look up the invoker for this component
//!     Some((invoker, release_fn))
//! });
//! handle_rpc_stream(stream, getter).await?;
//! ```

mod rpcstream;
mod writer;

// Include the generated protobuf types.
include!("rpcstream.pb.rs");

pub use rpcstream::*;
pub use writer::*;