Searched refs:ServingStatus (Results 1 – 4 of 4) sorted by relevance
| /tonic/tonic-health/src/ |
| H A D | lib.rs | 49 pub enum ServingStatus { enum
58 impl Display for ServingStatus { implementation
61 ServingStatus::Unknown => f.write_str("Unknown"), in fmt()
62 ServingStatus::Serving => f.write_str("Serving"), in fmt()
63 ServingStatus::NotServing => f.write_str("NotServing"), in fmt()
68 impl From<ServingStatus> for pb::health_check_response::ServingStatus { implementation
69 fn from(s: ServingStatus) -> Self { in from()
71 ServingStatus::Unknown => pb::health_check_response::ServingStatus::Unknown, in from()
72 ServingStatus::Serving => pb::health_check_response::ServingStatus::Serving, in from()
73 ServingStatus::NotServing => pb::health_check_response::ServingStatus::NotServing, in from()
|
| H A D | server.rs | 5 use crate::ServingStatus;
29 type StatusPair = (watch::Sender<ServingStatus>, watch::Receiver<ServingStatus>);
56 self.set_service_status(service_name, ServingStatus::Serving) in set_serving()
149 inner: tokio_stream::wrappers::WatchStream<ServingStatus>,
153 fn new(status_rx: watch::Receiver<ServingStatus>) -> Self { in new()
179 fn new(status: ServingStatus) -> Self { in new()
190 use crate::ServingStatus;
195 fn assert_serving_status(wire: i32, expected: ServingStatus) { in assert_serving_status() argument
213 watch::channel(ServingStatus::Unknown), in make_test_service()
233 assert_serving_status(resp.status, ServingStatus::Serving); in test_service_check()
[all …]
|
| /tonic/tonic-health/proto/ |
| H A D | health.proto | 33 enum ServingStatus { enum
39 ServingStatus status = 1;
|
| /tonic/tonic-health/src/generated/ |
| H A D | grpc_health_v1.rs | 26 pub enum ServingStatus { enum
33 impl ServingStatus { implementation
|