Struct HaProxyService 

pub struct HaProxyService<S> { /* private fields */ }

Service to decode the HaProxy Protocol

This service will decode the HaProxy Protocol header and pass the decoded information to the inner service.

Implementations

impl<S> HaProxyService<S>

pub const fn new(inner: S) -> Self

Create a new HaProxyService with the given inner service.

pub fn with_peek(self, value: bool) -> Self

Instruct HaProxyService to peek prior to comitting to the HaProxy protocol.

Doing so makes it possible to support traffic with or without the use of that data. This can be useful to run services locally (not behind a loadbalancer) as well as in the the cloud (production, behind a loadbalancer).

pub fn set_peek(&mut self, value: bool) -> &mut Self

Instruct HaProxyService to peek prior to comitting to the HaProxy protocol.

Doing so makes it possible to support traffic with or without the use of that data. This can be useful to run services locally (not behind a loadbalancer) as well as in the the cloud (production, behind a loadbalancer).

pub fn with_strictness(self, value: HaProxyStrictness) -> Self

Override the strictness configuration applied to incoming PROXY headers.

pub fn set_strictness(&mut self, value: HaProxyStrictness) -> &mut Self

Override the strictness configuration applied to incoming PROXY headers.

Trait Implementations

impl<S: Clone> Clone for HaProxyService<S>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<S: Debug> Debug for HaProxyService<S>

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

Formats the value using the given formatter.

impl<S, IO> Service<IO> for HaProxyService<S>

where S: Service<PrefixedIo<HeapReader, IO>, Error: Into<BoxError>>, IO: Io + Unpin + ExtensionsRef,

type Output = <S as Service<PrefixedIo<HeapReader, IO>>>::Output

The type of the output returned by the service.

type Error = Box<dyn Error + Send + Sync>

The type of error returned by the service.

async fn serve(&self, stream: IO) -> Result<Self::Output, Self::Error>

Serve an output or an error for the given input

fn boxed(self) -> BoxService<Input, Self::Output, Self::Error>

Box this service to allow for dynamic dispatch.