Struct Pool 

pub struct Pool { /* private fields */ }

tcp连接池 连接池中的连接受max_conn数据限制 keepalive数据没有任何效果 连接池中的连接不复用, get出来后tcp stream不被引用则会导致连接断开

Implementations

impl Pool

pub fn new(strategy: Arc<dyn Strategy>) -> Self

Trait Implementations

impl Default for Pool

fn default() -> Self

Returns the “default value” for a type.

impl<L: Strategy + 'static> From<L> for Pool

fn from(value: L) -> Self

Converts to this type from the input type.

impl Pool for Pool

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

设置最大连接数

fn get_max_conn(&self) -> Option<usize>

获取最大连接数

fn get_cur_conn(&self) -> usize

获取当前的连接数

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

设置空闲连接保留时长

fn get_keepalive(&self) -> Option<Duration>

获取空闲连接保留时长

fn get_strategy(&self) -> Arc<dyn Strategy>

获取转发策略

fn id(&self) -> &str

id

fn add_backend(&self, id: Option<u32>, addr: Address)

添加一个后端地址

fn get_backend(&self, key: &str) -> Option<BackendState>

根据策略获取一个后端

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

移除一个后端地址

fn get_backends(&self) -> Vec<BackendState>

获取所有后端地址切片

fn get_backend_by_id(&self, id: u32) -> Option<BackendState>

fn get_backend_by_code(&self, code: u64) -> Option<BackendState>

fn use_tls(&self, _: bool)

fn tls(&self) -> bool

impl TcpPool for Pool

async fn get(self: Arc<Self>, key: &str) -> Result<TcpStream, Error>