trillium-grpc 0.2.0

gRPC server and client for trillium, built on trillium-http's h2/h2c/h3 support
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

//! The client half of trillium-grpc.
//!
//! A generated `<Service>Client` wraps a [`trillium_client::Client`] and exposes
//! one method per RPC. Each returns a typed, shape-specific call handle —
//! [`UnaryConn`], [`StreamingConn`], or [`BidiConn`] — built on the
//! [`GrpcClientConn`] engine: configure it with chainable `with_*` setters, then
//! `.await` and/or iterate it to run the call and read the response, its initial
//! metadata, and its `grpc-status` trailers. Per-client configuration
//! (compression, deadlines) lives on [`ServiceClientExt`].

mod conn;
mod service_client;
mod typed;

pub use conn::{CancelHandle, GrpcClientConn};
pub use service_client::{ServiceClient, ServiceClientExt};
pub use typed::{BidiConn, StreamingConn, UnaryConn};

/// Append a service-prefix segment to the client's base URL. Used by
/// generated `From<trillium_client::Client>` impls so that each generated
/// method only needs to specify its own RPC name as a relative path.
///
/// Mutates the base in place — `trillium_client::Client::base_mut` is
/// clone-on-write across clones of the same client, so this doesn't leak
/// to other holders.
///
/// Panics if the client has no base URL set.
pub fn with_service_prefix(
    mut client: trillium_client::Client,
    prefix: &str,
) -> trillium_client::Client {
    let base = client
        .base_mut()
        .expect("trillium_client::Client must have a base url set");
    let new_path = format!("{}/{prefix}/", base.path().trim_end_matches('/'));
    base.set_path(&new_path);
    client
}