aioduct 0.2.5

Async-native HTTP client built directly on hyper 1.x — no hyper-util, no legacy
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
48
49
50
51
52
53
54
55
56
57

//! Host-side Wasmtime WASI HTTP adapter backed by native `aioduct`.
//!
//! This module is for hosts embedding WASI Preview 2 components with
//! `wasi:http`. Guests keep using `aioduct::WasiClient`; the host installs
//! `WasiHttpHost` as the Wasmtime HTTP hook and owns transport trust policy.
//!
//! The default feature set is empty. Enable exactly the native host transport
//! runtime you want to use, such as `tokio`, `smol`, or `compio`, plus a rustls
//! provider when the native transport needs TLS.
//!
//! Runnable host examples live under `examples/wasmtime-host` in the workspace.
//! They show a WASI guest component using `aioduct::WasiClient` while the host
//! validates origin policy, injects a host-owned header, and forwards through
//! Tokio, smol, or compio native transports.

#![deny(missing_docs)]

mod body;
mod host;
mod policy;
mod transport;

pub use host::{WasiHttpHost, WasiHttpHostBuilder};
pub use policy::{BuildError, ExactOriginPolicy, PolicyError, RejectionReason};
#[cfg(feature = "smol")]
pub use transport::SmolTransportBuilder;
#[cfg(feature = "tokio")]
pub use transport::TokioTransportBuilder;
pub use transport::{BoxFuture, HostForwardOptions, HostResponse, WasiHostTransport};
#[cfg(feature = "compio")]
pub use transport::{CompioHostTransport, CompioTransportBuilder};

#[cfg(test)]
pub(crate) use body::request_body_limit_from_error;
pub(crate) use body::{
    DeadlineBody, RequestLimitBody, ResponseLimitBody, map_aioduct_error, map_wasi_body_error,
};
#[cfg(test)]
pub(crate) use policy::RejectionObserver;

mod sealed {
    /// Marker trait sealing [`WasiHostTransport`](crate::wasmtime::WasiHostTransport).
    pub trait Sealed {}

    impl<R, C> Sealed for crate::HttpEngineSend<R, C>
    where
        R: crate::RuntimePoll,
        C: crate::ConnectorSend,
    {
    }

    #[cfg(feature = "compio")]
    impl Sealed for super::CompioHostTransport {}
}

#[cfg(test)]
mod tests;