Struct ProxyProtocolAcceptor

pub struct ProxyProtocolAcceptor<A> { /* private fields */ }

Available on crate feature proxy_protocol only.

Acceptor wrapper for receiving Proxy Protocol headers.

Implementations

impl<A> ProxyProtocolAcceptor<A>

pub fn new(inner: A) -> Self

Create a new proxy protocol acceptor from an initial acceptor. This is compatible with tls acceptors.

pub fn parsing_timeout(self, val: Duration) -> Self

Override the default Proxy Header parsing timeout.

impl<A> ProxyProtocolAcceptor<A>

pub fn acceptor<Acceptor>( self, acceptor: Acceptor, ) -> ProxyProtocolAcceptor<Acceptor>

Overwrite inner acceptor.

Trait Implementations

impl<A, I, S> Accept<I, S> for ProxyProtocolAcceptor<A>

where A: Accept<I, S> + Clone, A::Stream: AsyncRead + AsyncWrite + Unpin, I: AsyncRead + AsyncWrite + Unpin + Send + 'static,

type Stream = <A as Accept<I, S>>::Stream

The modified or transformed IO stream produced by accept.

type Service = ForwardClientIp<<A as Accept<I, S>>::Service>

The modified or transformed service produced by accept.

type Future = ProxyProtocolAcceptorFuture<Pin<Box<dyn Future<Output = Result<(I, Option<SocketAddr>), Error>> + Send>>, A, I, S>

The Future type that is returned by accept.

fn accept(&self, stream: I, service: S) -> Self::Future

Asynchronously process and possibly modify the given IO stream and service.

impl<A: Clone> Clone for ProxyProtocolAcceptor<A>

fn clone(&self) -> ProxyProtocolAcceptor<A>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<A> Debug for ProxyProtocolAcceptor<A>

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

Formats the value using the given formatter.