Home
last modified time | relevance | path

Searched refs:HealthCheckResponse (Results 1 – 19 of 19) sorted by relevance

/third_party/grpc/src/csharp/Grpc.HealthCheck/
DHealthServiceImpl.cs46 private readonly Dictionary<string, HealthCheckResponse.Types.ServingStatus> statusMap =
47 new Dictionary<string, HealthCheckResponse.Types.ServingStatus>();
51 private readonly Dictionary<string, List<ChannelWriter<HealthCheckResponse>>> watchers =
52 new Dictionary<string, List<ChannelWriter<HealthCheckResponse>>>();
60 public void SetStatus(string service, HealthCheckResponse.Types.ServingStatus status) in SetStatus()
62 HealthCheckResponse.Types.ServingStatus previousStatus; in SetStatus()
83 HealthCheckResponse.Types.ServingStatus previousStatus; in ClearStatus()
91 if (previousStatus != HealthCheckResponse.Types.ServingStatus.ServiceUnknown) in ClearStatus()
93 NotifyStatus(service, HealthCheckResponse.Types.ServingStatus.ServiceUnknown); in ClearStatus()
103 List<KeyValuePair<string, HealthCheckResponse.Types.ServingStatus>> statuses; in ClearAll()
[all …]
DHealth.cs43 …HealthCheckResponse), global::Grpc.Health.V1.HealthCheckResponse.Parser, new[]{ "Status" }, null, … in HealthReflection()
222 public sealed partial class HealthCheckResponse : pb::IMessage<HealthCheckResponse> class
227 …adonly pb::MessageParser<HealthCheckResponse> _parser = new pb::MessageParser<HealthCheckResponse>…
230 public static pb::MessageParser<HealthCheckResponse> Parser { get { return _parser; } }
243 public HealthCheckResponse() { in HealthCheckResponse() method in Grpc.Health.V1.HealthCheckResponse
250 public HealthCheckResponse(HealthCheckResponse other) : this() { in HealthCheckResponse() method in Grpc.Health.V1.HealthCheckResponse
256 public HealthCheckResponse Clone() { in Clone()
257 return new HealthCheckResponse(this); in Clone()
262 …rivate global::Grpc.Health.V1.HealthCheckResponse.Types.ServingStatus status_ = global::Grpc.Healt…
264 public global::Grpc.Health.V1.HealthCheckResponse.Types.ServingStatus Status {
[all …]
DHealthGrpc.cs64 …HealthCheckResponse> __Marshaller_grpc_health_v1_HealthCheckResponse = grpc::Marshallers.Create(__…
66 …th.V1.HealthCheckResponse> __Method_Check = new grpc::Method<global::Grpc.Health.V1.HealthCheckReq…
73 …th.V1.HealthCheckResponse> __Method_Watch = new grpc::Method<global::Grpc.Health.V1.HealthCheckReq…
97 …public virtual global::System.Threading.Tasks.Task<global::Grpc.Health.V1.HealthCheckResponse> Che… in Check()
123 …kRequest request, grpc::IServerStreamWriter<global::Grpc.Health.V1.HealthCheckResponse> responseSt… in Watch()
162 …public virtual global::Grpc.Health.V1.HealthCheckResponse Check(global::Grpc.Health.V1.HealthCheck… in Check()
173 …public virtual global::Grpc.Health.V1.HealthCheckResponse Check(global::Grpc.Health.V1.HealthCheck… in Check()
186 …public virtual grpc::AsyncUnaryCall<global::Grpc.Health.V1.HealthCheckResponse> CheckAsync(global:… in CheckAsync()
197 …public virtual grpc::AsyncUnaryCall<global::Grpc.Health.V1.HealthCheckResponse> CheckAsync(global:… in CheckAsync()
223 …public virtual grpc::AsyncServerStreamingCall<global::Grpc.Health.V1.HealthCheckResponse> Watch(gl… in Watch()
[all …]
/third_party/grpc/src/csharp/Grpc.HealthCheck.Tests/
DHealthServiceImplTest.cs40 impl.SetStatus("", HealthCheckResponse.Types.ServingStatus.Serving); in SetStatus()
41 … Assert.AreEqual(HealthCheckResponse.Types.ServingStatus.Serving, GetStatusHelper(impl, "")); in SetStatus()
43 impl.SetStatus("", HealthCheckResponse.Types.ServingStatus.NotServing); in SetStatus()
44 … Assert.AreEqual(HealthCheckResponse.Types.ServingStatus.NotServing, GetStatusHelper(impl, "")); in SetStatus()
46 impl.SetStatus("", HealthCheckResponse.Types.ServingStatus.Unknown); in SetStatus()
47 … Assert.AreEqual(HealthCheckResponse.Types.ServingStatus.Unknown, GetStatusHelper(impl, "")); in SetStatus()
49 … impl.SetStatus("grpc.test.TestService", HealthCheckResponse.Types.ServingStatus.Serving); in SetStatus()
50 …Assert.AreEqual(HealthCheckResponse.Types.ServingStatus.Serving, GetStatusHelper(impl, "grpc.test.… in SetStatus()
57 impl.SetStatus("", HealthCheckResponse.Types.ServingStatus.Serving); in ClearStatus()
58 … impl.SetStatus("grpc.test.TestService", HealthCheckResponse.Types.ServingStatus.Unknown); in ClearStatus()
[all …]
DTestResponseStreamWriter.cs26 internal class TestResponseStreamWriter : IServerStreamWriter<HealthCheckResponse>
28 private readonly Channel<HealthCheckResponse> _channel;
33 …_channel = System.Threading.Channels.Channel.CreateBounded<HealthCheckResponse>(new BoundedChannel… in TestResponseStreamWriter()
44 public ChannelReader<HealthCheckResponse> WrittenMessagesReader => _channel.Reader;
48 public async Task WriteAsync(HealthCheckResponse message) in WriteAsync()
DHealthClientServerTest.cs68 serviceImpl.SetStatus("", HealthCheckResponse.Types.ServingStatus.Serving); in ServiceIsRunning()
71 Assert.AreEqual(HealthCheckResponse.Types.ServingStatus.Serving, response.Status); in ServiceIsRunning()
/third_party/grpc/test/cpp/end2end/
Dhealth_service_end2end_test.cc47 using grpc::health::v1::HealthCheckResponse;
60 impl_->SetStatus("", HealthCheckResponse::SERVING); in CustomHealthCheckService()
64 impl_->SetStatus(service_name, serving ? HealthCheckResponse::SERVING in SetServingStatus()
65 : HealthCheckResponse::NOT_SERVING); in SetServingStatus()
69 impl_->SetAll(serving ? HealthCheckResponse::SERVING in SetServingStatus()
70 : HealthCheckResponse::NOT_SERVING); in SetServingStatus()
137 HealthCheckResponse::UNKNOWN); in SendHealthCheckRpc()
142 HealthCheckResponse::ServingStatus expected_serving_status) { in SendHealthCheckRpc()
145 HealthCheckResponse response; in SendHealthCheckRpc()
165 SendHealthCheckRpc("", Status::OK, HealthCheckResponse::SERVING); in VerifyHealthCheckService()
[all …]
Dtest_health_check_service_impl.cc24 using grpc::health::v1::HealthCheckResponse;
31 HealthCheckResponse* response) { in Check()
43 ::grpc::ServerWriter<HealthCheckResponse>* writer) { in Watch()
44 auto last_state = HealthCheckResponse::UNKNOWN; in Watch()
48 HealthCheckResponse response; in Watch()
68 HealthCheckResponse::ServingStatus status) { in SetStatus()
71 status = HealthCheckResponse::NOT_SERVING; in SetStatus()
76 void HealthCheckServiceImpl::SetAll(HealthCheckResponse::ServingStatus status) { in SetAll()
93 iter->second = HealthCheckResponse::NOT_SERVING; in Shutdown()
Dtest_health_check_service_impl.h38 health::v1::HealthCheckResponse* response) override;
41 ServerWriter<health::v1::HealthCheckResponse>* writer) override;
43 health::v1::HealthCheckResponse::ServingStatus status);
44 void SetAll(health::v1::HealthCheckResponse::ServingStatus status);
51 std::map<const std::string, health::v1::HealthCheckResponse::ServingStatus>
/third_party/grpc/src/python/grpcio_tests/tests_aio/health_check/
Dhealth_servicer_test.py51 health_pb2.HealthCheckResponse.SERVING)
53 health_pb2.HealthCheckResponse.UNKNOWN)
55 health_pb2.HealthCheckResponse.NOT_SERVING)
72 self.assertEqual(health_pb2.HealthCheckResponse.SERVING, resp.status)
77 self.assertEqual(health_pb2.HealthCheckResponse.SERVING, resp.status)
82 self.assertEqual(health_pb2.HealthCheckResponse.UNKNOWN, resp.status)
87 self.assertEqual(health_pb2.HealthCheckResponse.NOT_SERVING,
107 self.assertEqual(health_pb2.HealthCheckResponse.SERVING,
123 self.assertEqual(health_pb2.HealthCheckResponse.SERVICE_UNKNOWN,
127 health_pb2.HealthCheckResponse.SERVING)
[all …]
/third_party/grpc/src/python/grpcio_tests/tests/health_check/
D_health_servicer_test.py54 health_pb2.HealthCheckResponse.SERVING)
56 health_pb2.HealthCheckResponse.UNKNOWN)
58 health_pb2.HealthCheckResponse.NOT_SERVING)
81 self.assertEqual(health_pb2.HealthCheckResponse.SERVING,
100 self.assertEqual(health_pb2.HealthCheckResponse.SERVICE_UNKNOWN,
104 health_pb2.HealthCheckResponse.SERVING)
106 self.assertEqual(health_pb2.HealthCheckResponse.SERVING,
110 health_pb2.HealthCheckResponse.NOT_SERVING)
112 self.assertEqual(health_pb2.HealthCheckResponse.NOT_SERVING,
128 self.assertEqual(health_pb2.HealthCheckResponse.SERVICE_UNKNOWN,
[all …]
/third_party/grpc/src/python/grpcio_health_checking/grpc_health/v1/
D_async.py33 self._server_status = {"": _health_pb2.HealthCheckResponse.SERVING}
44 return _health_pb2.HealthCheckResponse(status=status)
55 _health_pb2.HealthCheckResponse.SERVICE_UNKNOWN)
63 _health_pb2.HealthCheckResponse(status=status))
76 status: _health_pb2.HealthCheckResponse.ServingStatus) -> None:
87 status: _health_pb2.HealthCheckResponse.ServingStatus) -> None:
113 _health_pb2.HealthCheckResponse.NOT_SERVING)
Dhealth.py88 self._server_status = {"": _health_pb2.HealthCheckResponse.SERVING}
109 return _health_pb2.HealthCheckResponse()
111 return _health_pb2.HealthCheckResponse(status=status)
127 … status = _health_pb2.HealthCheckResponse.SERVICE_UNKNOWN # pylint: disable=no-member
129 _health_pb2.HealthCheckResponse(status=status))
154 _health_pb2.HealthCheckResponse(status=status))
171 … _health_pb2.HealthCheckResponse.NOT_SERVING) # pylint: disable=no-member
/third_party/grpc/src/ruby/pb/grpc/health/
Dchecker.rb25 HealthCheckResponse = V1::HealthCheckResponse constant in Grpc.Health.Checker
42 HealthCheckResponse.new(status: status)
/third_party/grpc/src/proto/grpc/health/v1/
Dhealth.proto32 message HealthCheckResponse { message
45 rpc Check(HealthCheckRequest) returns (HealthCheckResponse);
62 rpc Watch(HealthCheckRequest) returns (stream HealthCheckResponse);
/third_party/grpc/examples/csharp/Xds/GreeterServer/
DProgram.cs81 …healthServiceImpl.SetStatus(serviceDescriptor.FullName, HealthCheckResponse.Types.ServingStatus.Se… in RunServer()
84 healthServiceImpl.SetStatus("", HealthCheckResponse.Types.ServingStatus.Serving); in RunServer()
/third_party/grpc/doc/
Dhealth-checking.md35 message HealthCheckResponse {
46 rpc Check(HealthCheckRequest) returns (HealthCheckResponse);
48 rpc Watch(HealthCheckRequest) returns (stream HealthCheckResponse);
/third_party/grpc/src/ruby/pb/grpc/health/v1/
Dhealth_pb.rb27 …HealthCheckResponse = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("grpc.health.v1.Hea… constant
/third_party/grpc/examples/python/xds/
Dserver.py74 health_servicer.set(service, health_pb2.HealthCheckResponse.SERVING)