Struct Forwarder 

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

Available on crate features tcp and http only.

A TCP forwarder.

Implementations

impl Forwarder<TcpConnector>

pub fn new(target: impl Into<HostWithPort>) -> Forwarder<TcpConnector>

Create a new static forwarder for the given target HostWithPort

pub fn ctx() -> Forwarder<TcpConnector>

Create a new dynamic forwarder, which will fetch the target from the [Context]

impl Forwarder<TcpConnector>

pub fn with_connector<T>(self, connector: T) -> Forwarder<T>

Set a custom “connector” for this forwarder, overwriting the default tcp forwarder which simply establishes a TCP connection.

This can be useful for any custom middleware, but also to enrich with rama-provided services for tls connections, HAproxy client endoding or even an entirely custom tcp connector service.

Trait Implementations

impl<C> Clone for Forwarder<C>

where C: Clone,

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

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<C> Debug for Forwarder<C>

where C: Debug,

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

Formats the value using the given formatter.

impl<T, C> Service<T> for Forwarder<C>

where T: Stream + Unpin + ExtensionsMut, C: ConnectorService<Request>, <C as ConnectorService<Request>>::Connection: Stream + Unpin,

type Output = ()

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, source: T, ) -> Result<<Forwarder<C> as Service<T>>::Output, <Forwarder<C> as Service<T>>::Error>

Serve a an output or error for the given input, using the given context.

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

Box this service to allow for dynamic dispatch.