Struct ProxyConnector

pub struct ProxyConnector<C> { /* private fields */ }

A wrapper around Proxys with a connector.

Implementations

impl<C> ProxyConnector<C>

pub fn new(connector: C) -> Result<Self, Error>

Create a new secured Proxies

pub fn unsecured(connector: C) -> Self

Create a new unsecured Proxy

pub fn from_proxy(connector: C, proxy: Proxy) -> Result<Self, Error>

Create a proxy connector and attach a particular proxy

pub fn from_proxy_unsecured(connector: C, proxy: Proxy) -> Self

Create a proxy connector and attach a particular proxy

pub fn with_connector<CC>(self, connector: CC) -> ProxyConnector<CC>

Change proxy connector

pub fn set_tls(&mut self, tls: Option<NativeTlsConnector>)

Set or unset tls when tunneling

pub fn proxies(&self) -> &[Proxy]

Get the current proxies

pub fn add_proxy(&mut self, proxy: Proxy)

Add a new additional proxy

pub fn extend_proxies<I: IntoIterator<Item = Proxy>>(&mut self, proxies: I)

Extend the list of proxies

pub fn http_headers(&self, uri: &Uri) -> Option<&HeaderMap>

Get http headers for a matching uri

These headers must be appended to the hyper Request for the proxy to work properly. This is needed only for http requests.

Trait Implementations

impl<C: Clone> Clone for ProxyConnector<C>

fn clone(&self) -> ProxyConnector<C>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<C: Debug> Debug for ProxyConnector<C>

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

Formats the value using the given formatter.

impl<C> Service<Uri> for ProxyConnector<C>

where C: Service<Uri>, C::Response: AsyncRead + AsyncWrite + Send + Unpin + 'static, C::Future: Send + 'static, C::Error: Into<Box<dyn Error + Send + Sync>>,

type Response = ProxyStream<<C as Service<Uri>>::Response>

Responses given by the service.

type Error = Error

Errors produced by the service.

type Future = Pin<Box<dyn Future<Output = Result<<ProxyConnector<C> as Service<Uri>>::Response, <ProxyConnector<C> as Service<Uri>>::Error>> + Send>>

The future response value.

fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Error>>

Returns Poll::Ready(Ok(())) when the service is able to process requests.

fn call(&mut self, uri: Uri) -> Self::Future

Process the request and return the response asynchronously.