Struct HaProxyService 

pub struct HaProxyService<S, P = Tcp, V = Two> { /* private fields */ }

Service to encode and write the HaProxy Protocol as a client on the connected stream.

This connector should in most cases happen as the first thing after establishing the connection.

Implementations

impl<S> HaProxyService<S>

pub fn tcp(inner: S) -> Self

Create a new HaProxyService for the TCP protocol (default).

This is in the PROXY spec referred to as:

• TCP4 (for IPv4, v1)
• TCP6 (for IPv6, v1)
• Stream (v2)

pub fn v1(self) -> HaProxyService<S, Tcp, One>

Use version one of PROXY protocol, instead of the default version two.

Version one makes use of a less advanced text protocol, instead the more advanced binary v2 protocol.

Use this only if you have no control over a v1-only server.

impl<S> HaProxyService<S, Udp>

pub fn udp(inner: S) -> Self

Create a new HaProxyService for the UDP protocol, instead of the default TCP protocol.

This is in the PROXY spec referred to as:

• Datagram (v2)

impl<S, P> HaProxyService<S, P>

pub fn with_payload(self, payload: impl Into<Bytes>) -> Self

Attach a custom bytes payload to the PROXY header.

NOTE this is only possible in Version two of the PROXY Protocol. In case you downgrade this HaProxyLayer to version one later using Self::v1 this payload will be dropped.

pub fn set_payload(&mut self, payload: impl Into<Bytes>) -> &mut Self

Attach a custom bytes payload to the PROXY header.

NOTE this is only possible in Version two of the PROXY Protocol. In case you downgrade this HaProxyLayer to version one later using Self::v1 this payload will be dropped.

pub fn with_tlv(self, kind: Type, value: impl Into<Bytes>) -> Self

Attach a Type-Length-Value entry to the emitted v2 header. See HaProxyLayer::with_tlv for details.

pub fn set_tlv(&mut self, kind: Type, value: impl Into<Bytes>) -> &mut Self

Attach a Type-Length-Value entry to the emitted v2 header. See HaProxyLayer::with_tlv for details.

pub fn with_crc32c(self, enabled: bool) -> Self

Toggle automatic emission of a valid PP2_TYPE_CRC32C TLV. See [HaProxyLayer::crc32c] for details.

pub fn set_crc32c(&mut self, enabled: bool) -> &mut Self

Toggle automatic emission of a valid PP2_TYPE_CRC32C TLV. See [HaProxyLayer::crc32c] for details.

Trait Implementations

impl<S: Clone, P, V: Clone> Clone for HaProxyService<S, P, V>

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, P, V: Debug> Debug for HaProxyService<S, P, V>

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

Formats the value using the given formatter.

impl<S, P, Input> Service<Input> for HaProxyService<S, P, One>

where S: ConnectorService<Input, Connection: Io + Socket + Unpin>, P: Send + 'static, Input: Send + ExtensionsRef + 'static,

type Output = EstablishedClientConnection<<S as ConnectorService<Input>>::Connection, Input>

The type of the output returned by the service.

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

The type of error returned by the service.

async fn serve(&self, input: Input) -> 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.

impl<S, P, Input> Service<Input> for HaProxyService<S, P, Two>

where S: ConnectorService<Input, Connection: Io + Socket + Unpin>, P: Protocol + Send + 'static, Input: Send + ExtensionsRef + 'static,

type Output = EstablishedClientConnection<<S as ConnectorService<Input>>::Connection, Input>

The type of the output returned by the service.

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

The type of error returned by the service.

async fn serve(&self, input: Input) -> 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.