Struct Relay 

pub struct Relay<F, S, P = Pool>
where
    F: Fn(Arc<P>, TcpStream, SocketAddr) -> S,
    S: Future<Output = ()>,
    P: TcpPool + Pool,
{ /* private fields */ }

tcp relay

Implementations

impl<F, S, P> Relay<F, S, P>

where F: Fn(Arc<P>, TcpStream, SocketAddr) -> S, S: Future<Output = ()>, P: TcpPool + Pool,

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 pool(&self) -> Arc<P>

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

设置最大连接数

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

设置空闲连接保留时长

pub fn add_backend(&self, addr: Address)

添加一个后端地址

pub fn remove_backend(&self, addr: &Address) -> bool

移除一个后端地址

Trait Implementations

impl<F, S, P> Relay for Relay<F, S, P>

where F: Fn(Arc<P>, TcpStream, SocketAddr) -> S + Send + Sync + 'static, S: Future<Output = ()> + Send + 'static, P: TcpPool + Pool + Send + 'static,

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

异步运行