astu 0.0.0

Astu library
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

//! Underlying transport used by clients.

use anyhow::Result;
use async_trait::async_trait;
use enum_dispatch::enum_dispatch;

use crate::resolve::Target;

pub mod opaque;
pub mod tcp;
pub mod tcp_reuse;

/// Bytestream transports that will be used by clients to connect to targets.
#[non_exhaustive]
#[derive(Debug)]
pub enum Transport {
    /// No stream, will be handled by the client.
    Opaque,
    /// Async TCP stream.
    Tcp(tokio::net::TcpStream),
}

/// Factory for creating transports.
#[async_trait]
#[enum_dispatch]
pub trait TransportFactory {
    /// Sets up a transport to the target.
    async fn setup(&self, target: &Target) -> Result<Transport>;
}

/// All transport factory implementations.
#[enum_dispatch(TransportFactory)]
#[derive(Debug, Clone)]
pub enum TransportFactoryImpl {
    Opaque(opaque::TransportFactory),
    Tcp(tcp::TransportFactory),
    TcpReuse(tcp_reuse::TransportFactory),
}