HomeSort by relevance Sort by last modified time
    Searched refs:GaugeResponse (Results 1 - 15 of 15) sorted by null

  /external/grpc-grpc/src/ruby/pb/grpc/testing/
metrics_services_pb.rb 41 rpc :GetAllGauges, EmptyMessage, stream(GaugeResponse)
43 rpc :GetGauge, GaugeRequest, GaugeResponse
metrics_pb.rb 7 add_message "grpc.testing.GaugeResponse" do
24 GaugeResponse = Google::Protobuf::DescriptorPool.generated_pool.lookup("grpc.testing.GaugeResponse").msgclass
  /external/grpc-grpc/test/cpp/util/
metrics_server.h 74 ServerWriter<GaugeResponse>* writer) override;
77 GaugeResponse* response) override;
metrics_server.cc 55 ServerWriter<GaugeResponse>* writer) {
60 GaugeResponse resp;
71 GaugeResponse* response) {
  /external/grpc-grpc/test/cpp/interop/
metrics_client.cc 41 using grpc::testing::GaugeResponse;
60 std::unique_ptr<grpc::ClientReader<GaugeResponse>> reader(
63 GaugeResponse gauge_response;
66 if (gauge_response.value_case() == GaugeResponse::kLongValue) {
  /external/grpc-grpc-java/interop-testing/src/generated/main/grpc/io/grpc/testing/integration/
MetricsServiceGrpc.java 31 io.grpc.testing.integration.Metrics.GaugeResponse> getGetAllGaugesMethod;
36 responseType = io.grpc.testing.integration.Metrics.GaugeResponse.class,
39 io.grpc.testing.integration.Metrics.GaugeResponse> getGetAllGaugesMethod() {
40 io.grpc.MethodDescriptor<io.grpc.testing.integration.Metrics.EmptyMessage, io.grpc.testing.integration.Metrics.GaugeResponse> getGetAllGaugesMethod;
45 io.grpc.MethodDescriptor.<io.grpc.testing.integration.Metrics.EmptyMessage, io.grpc.testing.integration.Metrics.GaugeResponse>newBuilder()
53 io.grpc.testing.integration.Metrics.GaugeResponse.getDefaultInstance()))
63 io.grpc.testing.integration.Metrics.GaugeResponse> getGetGaugeMethod;
68 responseType = io.grpc.testing.integration.Metrics.GaugeResponse.class,
71 io.grpc.testing.integration.Metrics.GaugeResponse> getGetGaugeMethod() {
72 io.grpc.MethodDescriptor<io.grpc.testing.integration.Metrics.GaugeRequest, io.grpc.testing.integration.Metrics.GaugeResponse> getGetGaugeMethod
    [all...]
  /external/grpc-grpc/src/python/grpcio_tests/tests/stress/
metrics_server.py 39 return [metrics_pb2.GaugeResponse(name=GAUGE_NAME, long_value=qps)]
45 return metrics_pb2.GaugeResponse(name=GAUGE_NAME, long_value=qps)
  /external/grpc-grpc/src/csharp/Grpc.IntegrationTesting/
MetricsGrpc.cs 37 static readonly grpc::Marshaller<global::Grpc.Testing.GaugeResponse> __Marshaller_grpc_testing_GaugeResponse = grpc::Marshallers.Create((arg) => global::Google.Protobuf.MessageExtensions.ToByteArray(arg), global::Grpc.Testing.GaugeResponse.Parser.ParseFrom);
40 static readonly grpc::Method<global::Grpc.Testing.EmptyMessage, global::Grpc.Testing.GaugeResponse> __Method_GetAllGauges = new grpc::Method<global::Grpc.Testing.EmptyMessage, global::Grpc.Testing.GaugeResponse>(
47 static readonly grpc::Method<global::Grpc.Testing.GaugeRequest, global::Grpc.Testing.GaugeResponse> __Method_GetGauge = new grpc::Method<global::Grpc.Testing.GaugeRequest, global::Grpc.Testing.GaugeResponse>(
71 public virtual global::System.Threading.Tasks.Task GetAllGauges(global::Grpc.Testing.EmptyMessage request, grpc::IServerStreamWriter<global::Grpc.Testing.GaugeResponse> responseStream, grpc::ServerCallContext context)
82 public virtual global::System.Threading.Tasks.Task<global::Grpc.Testing.GaugeResponse> GetGauge(global::Grpc.Testing.GaugeRequest request, grpc::ServerCallContext context)
121 public virtual grpc::AsyncServerStreamingCall<global::Grpc.Testing.GaugeResponse> GetAllGauges(global::Grpc.Testing.EmptyMessage request, grpc::Metadata headers = null, global::System.DateTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threading.CancellationToken))
132 public virtual grpc::AsyncServerStreamingCall<global::Grpc.Testing.GaugeResponse> GetAllGauges(global::Grpc.Testing.EmptyMessage request, grpc::CallOptions options
    [all...]
Metrics.cs 39 new pbr::GeneratedClrTypeInfo(typeof(global::Grpc.Testing.GaugeResponse), global::Grpc.Testing.GaugeResponse.Parser, new[]{ "Name", "LongValue", "DoubleValue", "StringValue" }, new[]{ "Value" }, null, null),
51 public sealed partial class GaugeResponse : pb::IMessage<GaugeResponse> {
52 private static readonly pb::MessageParser<GaugeResponse> _parser = new pb::MessageParser<GaugeResponse>(() => new GaugeResponse());
55 public static pb::MessageParser<GaugeResponse> Parser { get { return _parser; } }
68 public GaugeResponse() {
75 public GaugeResponse(GaugeResponse other) : this()
    [all...]
StressTestClient.cs 253 public override Task<GaugeResponse> GetGauge(GaugeRequest request, ServerCallContext context)
259 return Task.FromResult(new GaugeResponse
268 public override async Task GetAllGauges(EmptyMessage request, IServerStreamWriter<GaugeResponse> responseStream, ServerCallContext context)
272 var response = new GaugeResponse
  /external/grpc-grpc-java/interop-testing/src/generated/main/java/io/grpc/testing/integration/
Metrics.java 18 // @@protoc_insertion_point(interface_extends:grpc.testing.GaugeResponse)
51 public io.grpc.testing.integration.Metrics.GaugeResponse.ValueCase getValueCase();
58 * Protobuf type {@code grpc.testing.GaugeResponse}
60 public static final class GaugeResponse extends
62 // @@protoc_insertion_point(message_implements:grpc.testing.GaugeResponse)
65 // Use GaugeResponse.newBuilder() to construct.
66 private GaugeResponse(com.google.protobuf.GeneratedMessageV3.Builder<?> builder) {
69 private GaugeResponse() {
78 private GaugeResponse(
147 io.grpc.testing.integration.Metrics.GaugeResponse.class, io.grpc.testing.integration.Metrics.GaugeResponse.Builder.class)
    [all...]
  /external/grpc-grpc/src/php/tests/qps/generated_code/Grpc/Testing/
GaugeResponse.php 14 * Generated from protobuf message <code>grpc.testing.GaugeResponse</code>
16 class GaugeResponse extends \Google\Protobuf\Internal\Message
  /external/grpc-grpc/src/ruby/stress/
metrics_server.rb 45 response = GaugeResponse.new(:name => gauge.get_name)
  /external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/
StressTestClientTest.java 28 import io.grpc.testing.integration.Metrics.GaugeResponse;
141 List<GaugeResponse> allGauges =
148 for (GaugeResponse gauge : allGauges) {
155 GaugeResponse gauge1 =
  /external/grpc-grpc-java/interop-testing/src/main/java/io/grpc/testing/integration/
StressTestClient.java 111 private final Map<String, Metrics.GaugeResponse> gauges =
112 new ConcurrentHashMap<String, Metrics.GaugeResponse>();
433 Metrics.GaugeResponse gauge = Metrics.GaugeResponse
569 StreamObserver<Metrics.GaugeResponse> responseObserver) {
570 for (Metrics.GaugeResponse gauge : gauges.values()) {
578 StreamObserver<Metrics.GaugeResponse> responseObserver) {
580 Metrics.GaugeResponse gauge = gauges.get(gaugeName);

Completed in 446 milliseconds