pub struct HealthChecker { /* private fields */ }Expand description
Manages health checks across all clusters and backends
Implementations§
Source§impl HealthChecker
impl HealthChecker
pub fn new() -> Self
Sourcepub fn owns_token(&self, token: Token) -> bool
pub fn owns_token(&self, token: Token) -> bool
Returns true iff token falls in the bounded range reserved for
health-check sockets. Critically, the upper bound prevents this
helper from falsely claiming the mux GOAWAY sentinel
Token(usize::MAX) (CVE-class regression caught during the
post-1209 rebase cross-check).
Sourcepub fn ready(&mut self, token: Token)
pub fn ready(&mut self, token: Token)
Called by the server event loop when mio reports readiness for a health check socket.
Sourcepub fn poll(&mut self, backends: &Rc<RefCell<BackendMap>>, registry: &Registry)
pub fn poll(&mut self, backends: &Rc<RefCell<BackendMap>>, registry: &Registry)
Called on each event loop iteration. Initiates new health checks when intervals have elapsed, and progresses in-flight checks.
pub fn remove_cluster(&mut self, cluster_id: &str)
Trait Implementations§
Source§impl Debug for HealthChecker
impl Debug for HealthChecker
Auto Trait Implementations§
impl Freeze for HealthChecker
impl RefUnwindSafe for HealthChecker
impl Send for HealthChecker
impl Sync for HealthChecker
impl Unpin for HealthChecker
impl UnsafeUnpin for HealthChecker
impl UnwindSafe for HealthChecker
Blanket Implementations§
Source§impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
Source§impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more