rs-zero 0.2.8

Rust-first microservice framework inspired by go-zero engineering practices
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

use crate::{
    discovery::{Discovery, DiscoveryError, DiscoveryResult},
    rpc::balancer::{RpcEndpoint, RpcEndpointSelector},
};

/// Resolves one RPC endpoint from discovery and selector state.
pub async fn resolve_service_endpoint<D, S>(
    discovery: &D,
    selector: &S,
    service: &str,
) -> DiscoveryResult<RpcEndpoint>
where
    D: Discovery + ?Sized,
    S: RpcEndpointSelector + ?Sized,
{
    let instances = discovery.discover(service).await?;
    selector
        .select(service, &instances)
        .ok_or_else(|| DiscoveryError::NoInstances {
            service: service.to_string(),
        })
}