Struct ConnectHealth 

pub struct ConnectHealth<B, N, H> { /* private fields */ }

Check answers for the whole server ("") and for mkit.transport.v1.TransportService: SERVING when both stores answer their probe, else NOT_SERVING. Any other name is not_found. Watch is unimplemented, which tells a Watch-capable client not to retry.

Implementations

impl<B, N, H> ConnectHealth<B, N, H>

pub fn new(pipeline: Arc<Pipeline<B, N, H>>) -> Self

Health over pipeline’s stores.

Trait Implementations

impl<B, N, H> Debug for ConnectHealth<B, N, H>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<B, N, H> Health for ConnectHealth<B, N, H>

where B: MultipartBlobStore + 'static, N: NamespaceStore + 'static, H: HookSet + 'static,

async fn check( &self, _ctx: RequestContext, request: ServiceRequest<'_, HealthCheckRequest>, ) -> ServiceResult<HealthCheckResponse>

Check returns the serving status of the requested service. If the service name is empty, the response covers the whole server.

async fn watch( &self, _ctx: RequestContext, _request: ServiceRequest<'_, HealthCheckRequest>, ) -> ServiceResult<ServiceStream<HealthCheckResponse>>

Watch performs a watch for the serving status of the requested service. The server will immediately send back a message indicating the current serving status. It will then subsequently send a new message whenever the service’s serving status changes.