volo-http 0.5.5

HTTP framework implementation of volo.
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
40
41
42
43
44
45
46
47

use std::error::Error;

use motore::{make::MakeConnection, service::UnaryService};
use volo::net::{Address, dial::DefaultMakeTransport};

use super::connector::PeerInfo;
use crate::error::{ClientError, client::request_error};

#[derive(Clone, Debug)]
pub struct PlainMakeConnection<MkC = DefaultMakeTransport> {
    mk_conn: MkC,
}

impl<MkC> PlainMakeConnection<MkC>
where
    MkC: MakeConnection<Address>,
{
    pub fn new(mk_conn: MkC) -> Self {
        Self { mk_conn }
    }
}

impl Default for PlainMakeConnection<DefaultMakeTransport> {
    fn default() -> Self {
        Self::new(DefaultMakeTransport::new())
    }
}

impl<MkC> UnaryService<PeerInfo> for PlainMakeConnection<MkC>
where
    MkC: MakeConnection<Address> + Sync,
    MkC::Error: Error + Send + Sync + 'static,
{
    type Response = MkC::Connection;
    type Error = ClientError;

    async fn call(&self, req: PeerInfo) -> Result<Self::Response, Self::Error> {
        tracing::debug!("[Volo-HTTP] connecting to target: {req:?}");
        match self.mk_conn.make_connection(req.address.clone()).await {
            Ok(conn) => Ok(conn),
            Err(err) => {
                tracing::warn!("[Volo-HTTP] failed to make connection, error: {err}");
                Err(request_error(err).with_address(req.address))
            }
        }
    }
}