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.

Trait Implementations

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

fn clone(&self) -> Self

Returns a copy 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<State, S, IO> Service<State, IO> for HaProxyService<S>

where State: Clone + Send + Sync + 'static, S: Service<State, Join<ChainReader<HeapReader, ReadHalf<IO>>, WriteHalf<IO>>, Error: Into<BoxError>>, IO: Stream + Unpin,

type Response = <S as Service<State, Join<ChainReader<HeapReader, ReadHalf<IO>>, WriteHalf<IO>>>>::Response

The type of response returned by the service.

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

The type of error returned by the service.

async fn serve( &self, ctx: Context<State>, stream: IO, ) -> Result<Self::Response, Self::Error>

Serve a response or error for the given request, using the given context.

fn boxed(self) -> BoxService<S, Request, Self::Response, Self::Error>

Box this service to allow for dynamic dispatch.