Lucio FrancoandGitHub
eba7ec7b32
This change introduces proper gRPC interceptors that are avilable regardless of the transport used. Each codegen service now produces an additional method called `with_interceptor` that accepts a `Interceptor`. All examples have been updated to use this new style and interop has a custom `tower::Service` middleware to echo the headers. There is also a new `interceptor` example that shows basic usage. BREAKING CHANGE: removed `interceptor_fn` and `intercep_headers_fn` from `transport` in favor of using `tonic::Interceptor`.
29 lines
790 B
Rust
29 lines
790 B
Rust
pub mod pb {
|
|
tonic::include_proto!("grpc.examples.echo");
|
|
}
|
|
|
|
use pb::{echo_client::EchoClient, EchoRequest};
|
|
use tonic::{metadata::MetadataValue, transport::Channel, Request};
|
|
|
|
#[tokio::main]
|
|
async fn main() -> Result<(), Box<dyn std::error::Error>> {
|
|
let channel = Channel::from_static("http://[::1]:50051").connect().await?;
|
|
|
|
let token = MetadataValue::from_str("Bearer some-auth-token")?;
|
|
|
|
let mut client = EchoClient::with_interceptor(channel, move |mut req: Request<()>| {
|
|
req.metadata_mut().insert("authorization", token.clone());
|
|
Ok(req)
|
|
});
|
|
|
|
let request = tonic::Request::new(EchoRequest {
|
|
message: "hello".into(),
|
|
});
|
|
|
|
let response = client.unary_echo(request).await?;
|
|
|
|
println!("RESPONSE={:?}", response);
|
|
|
|
Ok(())
|
|
}
|