pub struct DbHealthCheck { /* private fields */ }Expand description
Readiness probe over every pool in a DataSourceRegistry: pings each
primary and reports the first failure as Unhealthy naming the pool.
Register from on_start, where the frozen container hands out &'static
references:
ⓘ
let registry = container.get_arc::<DataSourceRegistry<ArclyDbPool>>();
health::global().register("database", DbHealthCheck::new(registry));Implementations§
Source§impl DbHealthCheck
impl DbHealthCheck
pub fn new(registry: Arc<DataSourceRegistry<ArclyDbPool>>) -> Self
Trait Implementations§
Source§impl HealthCheck for DbHealthCheck
impl HealthCheck for DbHealthCheck
fn check(&self) -> BoxFuture<'_, HealthStatus>
Auto Trait Implementations§
impl Freeze for DbHealthCheck
impl RefUnwindSafe for DbHealthCheck
impl Send for DbHealthCheck
impl Sync for DbHealthCheck
impl Unpin for DbHealthCheck
impl UnsafeUnpin for DbHealthCheck
impl UnwindSafe for DbHealthCheck
Blanket Implementations§
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
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
Source§impl<T> FutureExt for T
impl<T> FutureExt for T
Source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
Source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request