bayard 0.9.0

A distributed search server.
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51

use tonic::{Request, Response, Status};
use tracing::debug;

use crate::proto::healthcheck::{
    health_check_service_server::HealthCheckService as ProtoHealthCheckService,
    liveness_response::State as LivenessState, readiness_response::State as ReadinessState,
    LivenessRequest, LivenessResponse, ReadinessRequest, ReadinessResponse,
};

pub struct HealthCheckService {}

impl Default for HealthCheckService {
    fn default() -> Self {
        Self::new()
    }
}

impl HealthCheckService {
    pub fn new() -> Self {
        Self {}
    }
}

#[tonic::async_trait]
impl ProtoHealthCheckService for HealthCheckService {
    async fn liveness(
        &self,
        request: Request<LivenessRequest>,
    ) -> Result<Response<LivenessResponse>, Status> {
        debug!(?request, "liveness");

        let reply = LivenessResponse {
            state: LivenessState::Alive as i32,
        };

        Ok(Response::new(reply))
    }

    async fn readiness(
        &self,
        request: Request<ReadinessRequest>,
    ) -> Result<Response<ReadinessResponse>, Status> {
        debug!(?request, "liveness");

        let reply = ReadinessResponse {
            state: ReadinessState::Ready as i32,
        };

        Ok(Response::new(reply))
    }
}