Struct wmproxy::HealthCheck

pub struct HealthCheck { /* private fields */ }

健康检查的控制中心

Implementations

impl HealthCheck

pub fn new(fail_timeout: usize, max_fails: usize, min_rises: usize) -> Self

pub fn instance() -> &'static RwLock<HealthCheck>

pub fn check_can_request(addr: &SocketAddr, duration: Duration) -> bool

pub fn is_fall_down(addr: &SocketAddr) -> bool

检测状态是否能连接

pub fn check_fall_down( addr: &SocketAddr, fail_timeout: &Duration, fall_times: &usize, rise_times: &usize ) -> bool

检测状态是否能连接

pub fn add_fall_down(addr: SocketAddr)

失败时调用

pub fn add_rise_up(addr: SocketAddr)

成功时调用

pub async fn connect<A>(addr: &A) -> Result<TcpStream>

where A: ToSocketAddrs,

pub async fn connect_timeout<A>( addr: &A, connect: Option<Duration> ) -> Result<TcpStream>

where A: ToSocketAddrs,