Struct HttpProxy 

pub struct HttpProxy<L> { /* private fields */ }

Implementations

impl HttpProxy<Identity>

pub fn new(target_addr: String) -> Self

pub fn with_pool_config(target_addr: String, pool_config: PoolConfig) -> Self

impl<L> HttpProxy<L>

pub fn with_layer<NewL>(self, layer: NewL) -> HttpProxy<NewL>

pub fn handle_stream(&self, stream: VirtualStream)

where L: Layer<LocalProxyService> + Clone + Send + 'static, L::Service: Service<Request<Incoming>, Response = Response<BoxBody<Bytes, ProxyError>>, Error = Error> + Send + Clone + 'static, <L::Service as Service<Request<Incoming>>>::Future: Send,

pub fn handle_grpc_stream(&self, stream: VirtualStream)

where L: Layer<LocalProxyService> + Clone + Send + 'static, L::Service: Service<Request<Incoming>, Response = Response<BoxBody<Bytes, ProxyError>>, Error = Error> + Send + Clone + 'static, <L::Service as Service<Request<Incoming>>>::Future: Send,

Serve an incoming gRPC VirtualStream over HTTP/2.

gRPC requires HTTP/2 end-to-end so that trailers (grpc-status, grpc-message) are propagated correctly. This method uses a dedicated HTTP/2 connection pool (always acquired via acquire_h2()) to forward requests to the local service.

Trait Implementations

impl<L: Clone> Clone for HttpProxy<L>

fn clone(&self) -> HttpProxy<L>

Returns a duplicate of the value.

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

Performs copy-assignment from source.