Home
last modified time | relevance | path

Searched refs:ServingStatus (Results 1 – 14 of 14) sorted by relevance

/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 …]
DHealthClientServerTest.cs68 serviceImpl.SetStatus("", HealthCheckResponse.Types.ServingStatus.Serving); in ServiceIsRunning()
71 Assert.AreEqual(HealthCheckResponse.Types.ServingStatus.Serving, response.Status); in ServiceIsRunning()
/third_party/grpc/src/csharp/Grpc.HealthCheck/
DHealthServiceImpl.cs46 private readonly Dictionary<string, HealthCheckResponse.Types.ServingStatus> statusMap =
47 new Dictionary<string, HealthCheckResponse.Types.ServingStatus>();
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()
111 … foreach (KeyValuePair<string, HealthCheckResponse.Types.ServingStatus> status in statuses) in ClearAll()
113 if (status.Value != HealthCheckResponse.Types.ServingStatus.ServiceUnknown) in ClearAll()
[all …]
DHealth.cs43 … null, new[]{ typeof(global::Grpc.Health.V1.HealthCheckResponse.Types.ServingStatus) }, null, null) in HealthReflection()
262 …lth.V1.HealthCheckResponse.Types.ServingStatus status_ = global::Grpc.Health.V1.HealthCheckRespons…
264 public global::Grpc.Health.V1.HealthCheckResponse.Types.ServingStatus Status {
291 …if (Status != global::Grpc.Health.V1.HealthCheckResponse.Types.ServingStatus.Unknown) hash ^= Stat… in GetHashCode()
308 if (Status != global::Grpc.Health.V1.HealthCheckResponse.Types.ServingStatus.Unknown) { in WriteTo()
321 if (Status != global::Grpc.Health.V1.HealthCheckResponse.Types.ServingStatus.Unknown) { in IBufferMessage.InternalWriteTo()
334 if (Status != global::Grpc.Health.V1.HealthCheckResponse.Types.ServingStatus.Unknown) { in CalculateSize()
348 if (other.Status != global::Grpc.Health.V1.HealthCheckResponse.Types.ServingStatus.Unknown) { in MergeFrom()
366 … Status = (global::Grpc.Health.V1.HealthCheckResponse.Types.ServingStatus) input.ReadEnum(); in MergeFrom()
384 … Status = (global::Grpc.Health.V1.HealthCheckResponse.Types.ServingStatus) input.ReadEnum(); in IBufferMessage.InternalMergeFrom()
[all …]
/third_party/grpc/src/cpp/server/health/
Ddefault_health_check_service.h43 enum ServingStatus { NOT_FOUND, SERVING, NOT_SERVING }; enum
53 ServingStatus status) = 0;
123 ServingStatus /*status*/) override {} in SendHealth() argument
165 ServingStatus status) override;
174 ServingStatus status);
203 ServingStatus pending_status_ = NOT_FOUND; // Guarded by mu_.
217 static bool EncodeResponse(ServingStatus status, ByteBuffer* response);
242 ServingStatus GetServingStatus(const std::string& service_name) const;
252 void SetServingStatus(ServingStatus status);
253 ServingStatus GetServingStatus() const { return status_; } in GetServingStatus()
[all …]
Ddefault_health_check_service.cc56 const ServingStatus status = serving ? SERVING : NOT_SERVING; in SetServingStatus()
79 DefaultHealthCheckService::ServingStatus
127 ServingStatus status) { in SetServingStatus()
240 ServingStatus status, ByteBuffer* response) { in EncodeResponse()
311 ServingStatus serving_status = database_->GetServingStatus(service_name); in OnCallReceived()
410 SendHealth(std::shared_ptr<CallHandler> self, ServingStatus status) { in SendHealth()
423 SendHealthLocked(std::shared_ptr<CallHandler> self, ServingStatus status) { in SendHealthLocked()
/third_party/grpc/test/cpp/end2end/
Dtest_health_check_service_impl.h43 health::v1::HealthCheckResponse::ServingStatus status);
44 void SetAll(health::v1::HealthCheckResponse::ServingStatus status);
51 std::map<const std::string, health::v1::HealthCheckResponse::ServingStatus>
Dtest_health_check_service_impl.cc68 HealthCheckResponse::ServingStatus status) { in SetStatus()
76 void HealthCheckServiceImpl::SetAll(HealthCheckResponse::ServingStatus status) { in SetAll()
Dhealth_service_end2end_test.cc142 HealthCheckResponse::ServingStatus expected_serving_status) { in SendHealthCheckRpc()
/third_party/grpc/examples/csharp/Xds/GreeterServer/
DProgram.cs81 …ServiceImpl.SetStatus(serviceDescriptor.FullName, HealthCheckResponse.Types.ServingStatus.Serving); in RunServer()
84 healthServiceImpl.SetStatus("", HealthCheckResponse.Types.ServingStatus.Serving); in RunServer()
/third_party/grpc/src/python/grpcio_health_checking/grpc_health/v1/
D_async.py76 status: _health_pb2.HealthCheckResponse.ServingStatus) -> None: argument
87 status: _health_pb2.HealthCheckResponse.ServingStatus) -> None: argument
/third_party/grpc/src/proto/grpc/health/v1/
Dhealth.proto33 enum ServingStatus { enum
39 ServingStatus status = 1;
/third_party/grpc/doc/
Dhealth-checking.md36 enum ServingStatus {
42 ServingStatus status = 1;
/third_party/grpc/src/ruby/spec/pb/health/
Dchecker_spec.rb69 ServingStatus = Grpc::Health::V1::HealthCheckResponse::ServingStatus constant