Struct Pool

pub struct Pool { /* private fields */ }

http2连接池 连接池中的连接受max_conn数据限制 默认的keepalive是一分钟 连接池中的每个连接可并发流数受max_streams影响, 默认是20个 有三种行为会导致连接池中的连接被释放 1.对方主动关闭连接 2.remove_backend被调用清除后端地址, 这会导致该地址的所有连接失效 3.在外界没有引用sender达到keepalive时间后, 注意如果没有设置keepalive则此条无效

Implementations

impl Pool

pub fn new( id: String, strategy: Arc<dyn LbStrategy>, max_streams: Option<usize>, ) -> Self

pub fn set_max_streams(&self, max_streams: Option<usize>)

pub fn get_max_streams(&self) -> Option<usize>

Trait Implementations

impl Default for Pool

fn default() -> Self

Returns the “default value” for a type.

impl Http2Pool for Pool

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

fn get_id(&self) -> &String

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 LbStrategy>

获取转发策略

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

移除一个后端地址

fn use_tls(&self, tls: bool)

fn tls(&self) -> bool

fn add_backend(&self, addr: Address)

添加一个后端地址

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

获取所有后端地址切片