Struct Proxy 

#[non_exhaustive]
pub struct Proxy<U, C>
where
    U: Upstreams,
    C: Client,
{
    pub upstreams: U,
    pub client: C,
    pub url_path_getter: UrlPartGetter,
    pub url_query_getter: UrlPartGetter,
    pub host_header_getter: HostHeaderGetter,
    pub client_ip_forwarding_enabled: bool,
    pub strict_path_normalization_enabled: bool,
}

Handler that can proxy request to other server.

Fields (Non-exhaustive)

Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.

upstreams: U

Upstreams list.

client: C

Client for proxy.

url_path_getter: UrlPartGetter

Url path getter.

url_query_getter: UrlPartGetter

Url query getter.

host_header_getter: HostHeaderGetter

Host header getter

client_ip_forwarding_enabled: bool

Flag to enable x-forwarded-for header.

strict_path_normalization_enabled: bool

Flag to reject ambiguous percent-encoded path characters before proxying.

Implementations

impl<U> Proxy<U, HyperClient<HttpsConnector<HttpConnector>>>

where U: Upstreams, U::Error: Into<BoxedError>,

pub fn use_hyper_client(upstreams: U) -> Self

Available on crate feature hyper-client only.

Create a new Proxy using the default Hyper client.

This is a convenient way to create a proxy with standard configuration.

impl<U> Proxy<U, ReqwestClient>

where U: Upstreams, U::Error: Into<BoxedError>,

pub fn use_reqwest_client(upstreams: U) -> Self

Available on crate feature reqwest-client only.

Create a new Proxy using the default Reqwest client.

This is a convenient way to create a proxy with standard configuration.

impl<U> Proxy<U, UnixSockClient>

where U: Upstreams, U::Error: Into<BoxedError>,

pub fn use_unix_sock_tunnel(upstreams: U) -> Self

Available on crate feature unix-sock-client only.

Create a new Proxy that tunnels connections to a Unix socket.

impl<U, C> Proxy<U, C>

where U: Upstreams, U::Error: Into<BoxedError>, C: Client,

pub fn new(upstreams: U, client: C) -> Self

Create new Proxy with upstreams list.

pub fn with_client_ip_forwarding(upstreams: U, client: C) -> Self

Create new Proxy with upstreams list and enable x-forwarded-for header.

pub fn url_path_getter<G>(self, url_path_getter: G) -> Self

where G: Fn(&Request, &Depot) -> Option<String> + Send + Sync + 'static,

Set url path getter.

pub fn url_query_getter<G>(self, url_query_getter: G) -> Self

where G: Fn(&Request, &Depot) -> Option<String> + Send + Sync + 'static,

Set url query getter.

pub fn host_header_getter<G>(self, host_header_getter: G) -> Self

where G: Fn(&Uri, &Request, &Depot) -> Option<String> + Send + Sync + 'static,

Set host header query getter.

pub fn strict_path_normalization(self, enable: bool) -> Self

Enable or disable strict path normalization.

When enabled, the proxy rejects paths that still contain percent-encoded ., /, \, or % characters after Salvo routing has extracted the path tail. This is useful when the proxy is used as a security boundary and the upstream server may perform another decode pass.

pub fn upstreams(&self) -> &U

Get upstreams list.

pub fn upstreams_mut(&mut self) -> &mut U

Get upstreams mutable list.

pub fn client(&self) -> &C

Get client reference.

pub fn client_mut(&mut self) -> &mut C

Get client mutable reference.

pub fn client_ip_forwarding(self, enable: bool) -> Self

Enable x-forwarded-for header prepending.

Trait Implementations

impl<U, C> Debug for Proxy<U, C>

where U: Upstreams, C: Client,

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<U, C> Handler for Proxy<U, C>

where U: Upstreams, U::Error: Into<BoxedError>, C: Client,

fn handle<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 self, req: &'life1 mut Request, depot: &'life2 mut Depot, res: &'life3 mut Response, _ctrl: &'life4 mut FlowCtrl, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait,

Handle http request.

fn arc(self) -> ArcHandler

where Self: Sized,

Wrap to ArcHandler.

fn hooped<H>(self) -> HoopedHandler

where H: Handler, Self: Sized,

Wrap to HoopedHandler.

fn hoop<H>(self, hoop: H) -> HoopedHandler

where H: Handler, Self: Sized,

Hoop this handler with middleware.

fn hoop_when<H, F>(self, hoop: H, filter: F) -> HoopedHandler

where Self: Sized, H: Handler, F: Fn(&Request, &Depot) -> bool + Send + Sync + 'static,

Hoop this handler with middleware.