Struct LocalProxyService 

pub struct LocalProxyService { /* private fields */ }

Service that forwards requests to a local TCP port.

Implementations

impl LocalProxyService

pub fn new(target_addr: String) -> Self

pub fn with_pool(pool: Arc<ConnectionPool>) -> Self

pub fn with_pool_h2(pool: Arc<ConnectionPool>) -> Self

Create a service that uses HTTP/2 for forwarding (required for gRPC).

Trait Implementations

impl Clone for LocalProxyService

fn clone(&self) -> LocalProxyService

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<B> Service<Request<B>> for LocalProxyService

where B: Body<Data = Bytes> + Send + Sync + 'static, B::Error: Into<ProxyError> + Error + Send + Sync + 'static,

type Response = Response<BoxBody<Bytes, ProxyError>>

Responses given by the service.

type Error = Error

Errors produced by the service.

type Future = Pin<Box<dyn Future<Output = Result<<LocalProxyService as Service<Request<B>>>::Response, <LocalProxyService as Service<Request<B>>>::Error>> + Send>>

The future response value.

fn poll_ready(&mut self, _cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>

Returns Poll::Ready(Ok(())) when the service is able to process requests.

fn call(&mut self, req: Request<B>) -> Self::Future

Process the request and return the response asynchronously.