Struct Relay 

pub struct Relay<F, Ret, P = Pool>
where
    F: Fn(Pools<P>, Request<Incoming>) -> Ret,
    Ret: Future,
    P: Pool + HttpPool,
{ /* private fields */ }

http1 relay

Implementations

impl<F, Ret, P> Relay<F, Ret, P>

where F: Fn(Pools<P>, Request<Incoming>) -> Ret, Ret: Future, P: Pool + HttpPool,

pub fn build<B: FnOnce(Builder<P, F>) -> Builder<P, F>>( b: B, ) -> Result<Self, Error>

pub fn bind_addrs(&self) -> &Vec<SocketAddr>

pub fn relay_fn(&self) -> Arc<F>

pub fn set_max_conn(&self, max: Option<usize>)

设置最大连接数

pub fn set_keepalive(&self, duration: Option<Duration>)

设置空闲连接保留时长

pub fn pools(&self) -> Pools<P>

获取连接池管理器

pub fn set_pools(&mut self, ps: Pools<P>) -> Pools<P>

设置路由器

Trait Implementations

impl<F, Ret, ResBody, E, P> Relay for Relay<F, Ret, P>

where F: Fn(Pools<P>, Request<Incoming>) -> Ret + Send + Sync + 'static, Ret: Future<Output = Result<Response<ResBody>, E>> + Send + 'static, ResBody: Body + 'static + Send + Sync, ResBody::Error: Into<Box<dyn Error + Send + Sync>>, ResBody::Data: Send, E: Into<Box<dyn Error + Send + Sync>>, P: Pool + HttpPool + Send + 'static,

fn poll_run( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Result<(), Error>>

异步运行