ginepro 0.9.2

A client-side gRPC channel implementation for tonic
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

use std::time::Duration;

use ginepro::LoadBalancedChannel;

use anyhow::Context;

use shared_proto::pb::{echo_client::EchoClient, EchoRequest};

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    // By setting the resolution strategy to `Eagerly` the domain name is resolved
    // before the channel is created and ensures
    // that it will have a non-empty set of IPs to contact before the program starts.
    let channel = LoadBalancedChannel::builder(("localhost", 5000_u16))
        .resolution_strategy(ginepro::ResolutionStrategy::Eager {
            timeout: Duration::from_secs(20),
        })
        .channel()
        .await
        .context("failed to build LoadBalancedChannel")?;

    // Use the channel created above to drive the communication in EchoClient.
    let mut client = EchoClient::new(channel);

    let request = tonic::Request::new(EchoRequest {
        message: "hello".into(),
    });

    let response = client.unary_echo(request).await?;

    println!("RESPONSE={response:?}");

    Ok(())
}