Struct Forwarder

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

A TCP forwarder.

Implementations

impl Forwarder<TcpConnector>

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

Create a new static forwarder for the given target Authority

pub fn ctx() -> Forwarder<TcpConnector>

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

impl Forwarder<TcpConnector>

pub fn 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, C: ConnectorService<Request>, <C as ConnectorService<Request>>::Connection: Stream + Unpin, <C as ConnectorService<Request>>::Error: Into<Box<dyn Error + Sync + Send>>,

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

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

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

Box this service to allow for dynamic dispatch.