Struct IoToProxyBridgeIo 

pub struct IoToProxyBridgeIo<S, C = TcpConnector> { /* private fields */ }

Implementations

impl<S> IoToProxyBridgeIo<S>

pub fn new( inner: S, exec: Executor, target: HostWithPort, ) -> IoToProxyBridgeIo<S>

Creates a new IoToProxyBridgeIo service, which will use the provided target info to connect to.

Use Self::extension_proxy_target if you wish to have it be done using the ProxyTarget extension instead, failing the input flow in case that extension not exist.

pub fn extension_proxy_target(exec: Executor, inner: S) -> IoToProxyBridgeIo<S>

Creates a new IoToProxyBridgeIo service, which expects while serving that ProxyTarget is available in the input’s extension, and fail otherwise.

Use Self::new if you wish to use a hardcoded target instead,

pub fn get_ref(&self) -> &S

Gets a reference to the underlying service.

pub fn into_inner(self) -> S

Consumes self, returning the underlying service.

impl<S> IoToProxyBridgeIo<S>

pub fn with_connector<C>(self, connector: C) -> IoToProxyBridgeIo<S, C>

Set a custom “connector” for service, 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<S, C> Clone for IoToProxyBridgeIo<S, C>

where S: Clone, C: Clone,

fn clone(&self) -> IoToProxyBridgeIo<S, C>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<S, C> Debug for IoToProxyBridgeIo<S, C>

where S: Debug, C: Debug,

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

Formats the value using the given formatter.

impl<S, Ingress, C> Service<Ingress> for IoToProxyBridgeIo<S, C>

where S: Service<BridgeIo<Ingress, <C as ConnectorService<Request>>::Connection>>, <S as Service<BridgeIo<Ingress, <C as ConnectorService<Request>>::Connection>>>::Error: Into<Box<dyn Error + Send + Sync>>, Ingress: Io + ExtensionsRef, C: ConnectorService<Request>, <C as ConnectorService<Request>>::Connection: Io + Unpin,

type Output = <S as Service<BridgeIo<Ingress, <C as ConnectorService<Request>>::Connection>>>::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, ingress: Ingress, ) -> Result<<IoToProxyBridgeIo<S, C> as Service<Ingress>>::Output, <IoToProxyBridgeIo<S, C> as Service<Ingress>>::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.