mirror of https://github.com/grpc/grpc-java.git
benchmarks: move proto to matching package structure
This commit is contained in:
Carl Mastrangelo
GitHub
parent
017399027e
commit
b0333c6588
|
|
@ -19,7 +19,7 @@ import static io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall;
|
||||||
*/
|
*/
|
||||||
@javax.annotation.Generated(
|
@javax.annotation.Generated(
|
||||||
value = "by gRPC proto compiler",
|
value = "by gRPC proto compiler",
|
||||||
comments = "Source: services.proto")
|
comments = "Source: grpc/testing/services.proto")
|
||||||
public final class BenchmarkServiceGrpc {
|
public final class BenchmarkServiceGrpc {
|
||||||
|
|
||||||
private BenchmarkServiceGrpc() {}
|
private BenchmarkServiceGrpc() {}
|
||||||
|
|
|
||||||
|
|
@ -19,7 +19,7 @@ import static io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall;
|
||||||
*/
|
*/
|
||||||
@javax.annotation.Generated(
|
@javax.annotation.Generated(
|
||||||
value = "by gRPC proto compiler",
|
value = "by gRPC proto compiler",
|
||||||
comments = "Source: services.proto")
|
comments = "Source: grpc/testing/services.proto")
|
||||||
public final class ReportQpsScenarioServiceGrpc {
|
public final class ReportQpsScenarioServiceGrpc {
|
||||||
|
|
||||||
private ReportQpsScenarioServiceGrpc() {}
|
private ReportQpsScenarioServiceGrpc() {}
|
||||||
|
|
|
||||||
|
|
@ -19,7 +19,7 @@ import static io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall;
|
||||||
*/
|
*/
|
||||||
@javax.annotation.Generated(
|
@javax.annotation.Generated(
|
||||||
value = "by gRPC proto compiler",
|
value = "by gRPC proto compiler",
|
||||||
comments = "Source: services.proto")
|
comments = "Source: grpc/testing/services.proto")
|
||||||
public final class WorkerServiceGrpc {
|
public final class WorkerServiceGrpc {
|
||||||
|
|
||||||
private WorkerServiceGrpc() {}
|
private WorkerServiceGrpc() {}
|
||||||
|
|
|
||||||
|
|
@ -1,5 +1,5 @@
|
||||||
// Generated by the protocol buffer compiler. DO NOT EDIT!
|
// Generated by the protocol buffer compiler. DO NOT EDIT!
|
||||||
// source: control.proto
|
// source: grpc/testing/control.proto
|
||||||
|
|
||||||
package io.grpc.benchmarks.proto;
|
package io.grpc.benchmarks.proto;
|
||||||
|
|
||||||
|
|
@ -20206,86 +20206,87 @@ public final class Control {
|
||||||
descriptor;
|
descriptor;
|
||||||
static {
|
static {
|
||||||
java.lang.String[] descriptorData = {
|
java.lang.String[] descriptorData = {
|
||||||
"\n\rcontrol.proto\022\014grpc.testing\032\016payloads." +
|
"\n\032grpc/testing/control.proto\022\014grpc.testi" +
|
||||||
"proto\032\013stats.proto\"%\n\rPoissonParams\022\024\n\014o" +
|
"ng\032\033grpc/testing/payloads.proto\032\030grpc/te" +
|
||||||
"ffered_load\030\001 \001(\001\"\022\n\020ClosedLoopParams\"{\n" +
|
"sting/stats.proto\"%\n\rPoissonParams\022\024\n\014of" +
|
||||||
"\nLoadParams\0225\n\013closed_loop\030\001 \001(\0132\036.grpc." +
|
"fered_load\030\001 \001(\001\"\022\n\020ClosedLoopParams\"{\n\n" +
|
||||||
"testing.ClosedLoopParamsH\000\022.\n\007poisson\030\002 " +
|
"LoadParams\0225\n\013closed_loop\030\001 \001(\0132\036.grpc.t" +
|
||||||
"\001(\0132\033.grpc.testing.PoissonParamsH\000B\006\n\004lo" +
|
"esting.ClosedLoopParamsH\000\022.\n\007poisson\030\002 \001" +
|
||||||
"ad\"C\n\016SecurityParams\022\023\n\013use_test_ca\030\001 \001(" +
|
"(\0132\033.grpc.testing.PoissonParamsH\000B\006\n\004loa" +
|
||||||
"\010\022\034\n\024server_host_override\030\002 \001(\t\"M\n\nChann" +
|
"d\"C\n\016SecurityParams\022\023\n\013use_test_ca\030\001 \001(\010" +
|
||||||
"elArg\022\014\n\004name\030\001 \001(\t\022\023\n\tstr_value\030\002 \001(\tH\000" +
|
"\022\034\n\024server_host_override\030\002 \001(\t\"M\n\nChanne" +
|
||||||
"\022\023\n\tint_value\030\003 \001(\005H\000B\007\n\005value\"\275\004\n\014Clien" +
|
"lArg\022\014\n\004name\030\001 \001(\t\022\023\n\tstr_value\030\002 \001(\tH\000\022" +
|
||||||
"tConfig\022\026\n\016server_targets\030\001 \003(\t\022-\n\013clien" +
|
"\023\n\tint_value\030\003 \001(\005H\000B\007\n\005value\"\275\004\n\014Client" +
|
||||||
"t_type\030\002 \001(\0162\030.grpc.testing.ClientType\0225" +
|
"Config\022\026\n\016server_targets\030\001 \003(\t\022-\n\013client" +
|
||||||
"\n\017security_params\030\003 \001(\0132\034.grpc.testing.S" +
|
"_type\030\002 \001(\0162\030.grpc.testing.ClientType\0225\n" +
|
||||||
"ecurityParams\022$\n\034outstanding_rpcs_per_ch" +
|
"\017security_params\030\003 \001(\0132\034.grpc.testing.Se" +
|
||||||
"annel\030\004 \001(\005\022\027\n\017client_channels\030\005 \001(\005\022\034\n\024" +
|
"curityParams\022$\n\034outstanding_rpcs_per_cha" +
|
||||||
"async_client_threads\030\007 \001(\005\022\'\n\010rpc_type\030\010" +
|
"nnel\030\004 \001(\005\022\027\n\017client_channels\030\005 \001(\005\022\034\n\024a" +
|
||||||
" \001(\0162\025.grpc.testing.RpcType\022-\n\013load_para" +
|
"sync_client_threads\030\007 \001(\005\022\'\n\010rpc_type\030\010 " +
|
||||||
"ms\030\n \001(\0132\030.grpc.testing.LoadParams\0223\n\016pa" +
|
"\001(\0162\025.grpc.testing.RpcType\022-\n\013load_param" +
|
||||||
"yload_config\030\013 \001(\0132\033.grpc.testing.Payloa" +
|
"s\030\n \001(\0132\030.grpc.testing.LoadParams\0223\n\016pay" +
|
||||||
"dConfig\0227\n\020histogram_params\030\014 \001(\0132\035.grpc" +
|
"load_config\030\013 \001(\0132\033.grpc.testing.Payload" +
|
||||||
".testing.HistogramParams\022\021\n\tcore_list\030\r " +
|
"Config\0227\n\020histogram_params\030\014 \001(\0132\035.grpc." +
|
||||||
"\003(\005\022\022\n\ncore_limit\030\016 \001(\005\022\030\n\020other_client_" +
|
"testing.HistogramParams\022\021\n\tcore_list\030\r \003" +
|
||||||
"api\030\017 \001(\t\022.\n\014channel_args\030\020 \003(\0132\030.grpc.t" +
|
"(\005\022\022\n\ncore_limit\030\016 \001(\005\022\030\n\020other_client_a" +
|
||||||
"esting.ChannelArg\022\033\n\023messages_per_stream" +
|
"pi\030\017 \001(\t\022.\n\014channel_args\030\020 \003(\0132\030.grpc.te" +
|
||||||
"\030\022 \001(\005\"8\n\014ClientStatus\022(\n\005stats\030\001 \001(\0132\031." +
|
"sting.ChannelArg\022\033\n\023messages_per_stream\030" +
|
||||||
"grpc.testing.ClientStats\"\025\n\004Mark\022\r\n\005rese" +
|
"\022 \001(\005\"8\n\014ClientStatus\022(\n\005stats\030\001 \001(\0132\031.g" +
|
||||||
"t\030\001 \001(\010\"h\n\nClientArgs\022+\n\005setup\030\001 \001(\0132\032.g" +
|
"rpc.testing.ClientStats\"\025\n\004Mark\022\r\n\005reset" +
|
||||||
"rpc.testing.ClientConfigH\000\022\"\n\004mark\030\002 \001(\013" +
|
"\030\001 \001(\010\"h\n\nClientArgs\022+\n\005setup\030\001 \001(\0132\032.gr" +
|
||||||
"2\022.grpc.testing.MarkH\000B\t\n\007argtype\"\264\002\n\014Se" +
|
"pc.testing.ClientConfigH\000\022\"\n\004mark\030\002 \001(\0132" +
|
||||||
"rverConfig\022-\n\013server_type\030\001 \001(\0162\030.grpc.t" +
|
"\022.grpc.testing.MarkH\000B\t\n\007argtype\"\264\002\n\014Ser" +
|
||||||
"esting.ServerType\0225\n\017security_params\030\002 \001" +
|
"verConfig\022-\n\013server_type\030\001 \001(\0162\030.grpc.te" +
|
||||||
"(\0132\034.grpc.testing.SecurityParams\022\014\n\004port" +
|
"sting.ServerType\0225\n\017security_params\030\002 \001(" +
|
||||||
"\030\004 \001(\005\022\034\n\024async_server_threads\030\007 \001(\005\022\022\n\n" +
|
"\0132\034.grpc.testing.SecurityParams\022\014\n\004port\030" +
|
||||||
"core_limit\030\010 \001(\005\0223\n\016payload_config\030\t \001(\013" +
|
"\004 \001(\005\022\034\n\024async_server_threads\030\007 \001(\005\022\022\n\nc" +
|
||||||
"2\033.grpc.testing.PayloadConfig\022\021\n\tcore_li" +
|
"ore_limit\030\010 \001(\005\0223\n\016payload_config\030\t \001(\0132" +
|
||||||
"st\030\n \003(\005\022\030\n\020other_server_api\030\013 \001(\t\022\034\n\023re" +
|
"\033.grpc.testing.PayloadConfig\022\021\n\tcore_lis" +
|
||||||
"source_quota_size\030\351\007 \001(\005\"h\n\nServerArgs\022+" +
|
"t\030\n \003(\005\022\030\n\020other_server_api\030\013 \001(\t\022\034\n\023res" +
|
||||||
"\n\005setup\030\001 \001(\0132\032.grpc.testing.ServerConfi" +
|
"ource_quota_size\030\351\007 \001(\005\"h\n\nServerArgs\022+\n" +
|
||||||
"gH\000\022\"\n\004mark\030\002 \001(\0132\022.grpc.testing.MarkH\000B" +
|
"\005setup\030\001 \001(\0132\032.grpc.testing.ServerConfig" +
|
||||||
"\t\n\007argtype\"U\n\014ServerStatus\022(\n\005stats\030\001 \001(" +
|
"H\000\022\"\n\004mark\030\002 \001(\0132\022.grpc.testing.MarkH\000B\t" +
|
||||||
"\0132\031.grpc.testing.ServerStats\022\014\n\004port\030\002 \001" +
|
"\n\007argtype\"U\n\014ServerStatus\022(\n\005stats\030\001 \001(\013" +
|
||||||
"(\005\022\r\n\005cores\030\003 \001(\005\"\r\n\013CoreRequest\"\035\n\014Core" +
|
"2\031.grpc.testing.ServerStats\022\014\n\004port\030\002 \001(" +
|
||||||
"Response\022\r\n\005cores\030\001 \001(\005\"\006\n\004Void\"\375\001\n\010Scen" +
|
"\005\022\r\n\005cores\030\003 \001(\005\"\r\n\013CoreRequest\"\035\n\014CoreR" +
|
||||||
"ario\022\014\n\004name\030\001 \001(\t\0221\n\rclient_config\030\002 \001(" +
|
"esponse\022\r\n\005cores\030\001 \001(\005\"\006\n\004Void\"\375\001\n\010Scena" +
|
||||||
"\0132\032.grpc.testing.ClientConfig\022\023\n\013num_cli" +
|
"rio\022\014\n\004name\030\001 \001(\t\0221\n\rclient_config\030\002 \001(\013" +
|
||||||
"ents\030\003 \001(\005\0221\n\rserver_config\030\004 \001(\0132\032.grpc" +
|
"2\032.grpc.testing.ClientConfig\022\023\n\013num_clie" +
|
||||||
".testing.ServerConfig\022\023\n\013num_servers\030\005 \001" +
|
"nts\030\003 \001(\005\0221\n\rserver_config\030\004 \001(\0132\032.grpc." +
|
||||||
"(\005\022\026\n\016warmup_seconds\030\006 \001(\005\022\031\n\021benchmark_" +
|
"testing.ServerConfig\022\023\n\013num_servers\030\005 \001(" +
|
||||||
"seconds\030\007 \001(\005\022 \n\030spawn_local_worker_coun" +
|
"\005\022\026\n\016warmup_seconds\030\006 \001(\005\022\031\n\021benchmark_s" +
|
||||||
"t\030\010 \001(\005\"6\n\tScenarios\022)\n\tscenarios\030\001 \003(\0132" +
|
"econds\030\007 \001(\005\022 \n\030spawn_local_worker_count" +
|
||||||
"\026.grpc.testing.Scenario\"\274\003\n\025ScenarioResu" +
|
"\030\010 \001(\005\"6\n\tScenarios\022)\n\tscenarios\030\001 \003(\0132\026" +
|
||||||
"ltSummary\022\013\n\003qps\030\001 \001(\001\022\033\n\023qps_per_server" +
|
".grpc.testing.Scenario\"\274\003\n\025ScenarioResul" +
|
||||||
"_core\030\002 \001(\001\022\032\n\022server_system_time\030\003 \001(\001\022" +
|
"tSummary\022\013\n\003qps\030\001 \001(\001\022\033\n\023qps_per_server_" +
|
||||||
"\030\n\020server_user_time\030\004 \001(\001\022\032\n\022client_syst" +
|
"core\030\002 \001(\001\022\032\n\022server_system_time\030\003 \001(\001\022\030" +
|
||||||
"em_time\030\005 \001(\001\022\030\n\020client_user_time\030\006 \001(\001\022" +
|
"\n\020server_user_time\030\004 \001(\001\022\032\n\022client_syste" +
|
||||||
"\022\n\nlatency_50\030\007 \001(\001\022\022\n\nlatency_90\030\010 \001(\001\022" +
|
"m_time\030\005 \001(\001\022\030\n\020client_user_time\030\006 \001(\001\022\022" +
|
||||||
"\022\n\nlatency_95\030\t \001(\001\022\022\n\nlatency_99\030\n \001(\001\022" +
|
"\n\nlatency_50\030\007 \001(\001\022\022\n\nlatency_90\030\010 \001(\001\022\022" +
|
||||||
"\023\n\013latency_999\030\013 \001(\001\022\030\n\020server_cpu_usage" +
|
"\n\nlatency_95\030\t \001(\001\022\022\n\nlatency_99\030\n \001(\001\022\023" +
|
||||||
"\030\014 \001(\001\022&\n\036successful_requests_per_second" +
|
"\n\013latency_999\030\013 \001(\001\022\030\n\020server_cpu_usage\030" +
|
||||||
"\030\r \001(\001\022\"\n\032failed_requests_per_second\030\016 \001" +
|
"\014 \001(\001\022&\n\036successful_requests_per_second\030" +
|
||||||
"(\001\022 \n\030client_polls_per_request\030\017 \001(\001\022 \n\030" +
|
"\r \001(\001\022\"\n\032failed_requests_per_second\030\016 \001(" +
|
||||||
"server_polls_per_request\030\020 \001(\001\"\203\003\n\016Scena" +
|
"\001\022 \n\030client_polls_per_request\030\017 \001(\001\022 \n\030s" +
|
||||||
"rioResult\022(\n\010scenario\030\001 \001(\0132\026.grpc.testi" +
|
"erver_polls_per_request\030\020 \001(\001\"\203\003\n\016Scenar" +
|
||||||
"ng.Scenario\022.\n\tlatencies\030\002 \001(\0132\033.grpc.te" +
|
"ioResult\022(\n\010scenario\030\001 \001(\0132\026.grpc.testin" +
|
||||||
"sting.HistogramData\022/\n\014client_stats\030\003 \003(" +
|
"g.Scenario\022.\n\tlatencies\030\002 \001(\0132\033.grpc.tes" +
|
||||||
"\0132\031.grpc.testing.ClientStats\022/\n\014server_s" +
|
"ting.HistogramData\022/\n\014client_stats\030\003 \003(\013" +
|
||||||
"tats\030\004 \003(\0132\031.grpc.testing.ServerStats\022\024\n" +
|
"2\031.grpc.testing.ClientStats\022/\n\014server_st" +
|
||||||
"\014server_cores\030\005 \003(\005\0224\n\007summary\030\006 \001(\0132#.g" +
|
"ats\030\004 \003(\0132\031.grpc.testing.ServerStats\022\024\n\014" +
|
||||||
"rpc.testing.ScenarioResultSummary\022\026\n\016cli" +
|
"server_cores\030\005 \003(\005\0224\n\007summary\030\006 \001(\0132#.gr" +
|
||||||
"ent_success\030\007 \003(\010\022\026\n\016server_success\030\010 \003(" +
|
"pc.testing.ScenarioResultSummary\022\026\n\016clie" +
|
||||||
"\010\0229\n\017request_results\030\t \003(\0132 .grpc.testin" +
|
"nt_success\030\007 \003(\010\022\026\n\016server_success\030\010 \003(\010" +
|
||||||
"g.RequestResultCount*A\n\nClientType\022\017\n\013SY" +
|
"\0229\n\017request_results\030\t \003(\0132 .grpc.testing" +
|
||||||
"NC_CLIENT\020\000\022\020\n\014ASYNC_CLIENT\020\001\022\020\n\014OTHER_C" +
|
".RequestResultCount*A\n\nClientType\022\017\n\013SYN" +
|
||||||
"LIENT\020\002*[\n\nServerType\022\017\n\013SYNC_SERVER\020\000\022\020" +
|
"C_CLIENT\020\000\022\020\n\014ASYNC_CLIENT\020\001\022\020\n\014OTHER_CL" +
|
||||||
"\n\014ASYNC_SERVER\020\001\022\030\n\024ASYNC_GENERIC_SERVER" +
|
"IENT\020\002*[\n\nServerType\022\017\n\013SYNC_SERVER\020\000\022\020\n" +
|
||||||
"\020\002\022\020\n\014OTHER_SERVER\020\003*r\n\007RpcType\022\t\n\005UNARY" +
|
"\014ASYNC_SERVER\020\001\022\030\n\024ASYNC_GENERIC_SERVER\020" +
|
||||||
"\020\000\022\r\n\tSTREAMING\020\001\022\031\n\025STREAMING_FROM_CLIE" +
|
"\002\022\020\n\014OTHER_SERVER\020\003*r\n\007RpcType\022\t\n\005UNARY\020" +
|
||||||
"NT\020\002\022\031\n\025STREAMING_FROM_SERVER\020\003\022\027\n\023STREA" +
|
"\000\022\r\n\tSTREAMING\020\001\022\031\n\025STREAMING_FROM_CLIEN" +
|
||||||
"MING_BOTH_WAYS\020\004B#\n\030io.grpc.benchmarks.p" +
|
"T\020\002\022\031\n\025STREAMING_FROM_SERVER\020\003\022\027\n\023STREAM" +
|
||||||
"rotoB\007Controlb\006proto3"
|
"ING_BOTH_WAYS\020\004B#\n\030io.grpc.benchmarks.pr" +
|
||||||
|
"otoB\007Controlb\006proto3"
|
||||||
};
|
};
|
||||||
com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner assigner =
|
com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner assigner =
|
||||||
new com.google.protobuf.Descriptors.FileDescriptor. InternalDescriptorAssigner() {
|
new com.google.protobuf.Descriptors.FileDescriptor. InternalDescriptorAssigner() {
|
||||||
|
|
|
||||||
|
|
@ -1,5 +1,5 @@
|
||||||
// Generated by the protocol buffer compiler. DO NOT EDIT!
|
// Generated by the protocol buffer compiler. DO NOT EDIT!
|
||||||
// source: messages.proto
|
// source: grpc/testing/messages.proto
|
||||||
|
|
||||||
package io.grpc.benchmarks.proto;
|
package io.grpc.benchmarks.proto;
|
||||||
|
|
||||||
|
|
@ -10343,41 +10343,41 @@ public final class Messages {
|
||||||
descriptor;
|
descriptor;
|
||||||
static {
|
static {
|
||||||
java.lang.String[] descriptorData = {
|
java.lang.String[] descriptorData = {
|
||||||
"\n\016messages.proto\022\014grpc.testing\"\032\n\tBoolVa" +
|
"\n\033grpc/testing/messages.proto\022\014grpc.test" +
|
||||||
"lue\022\r\n\005value\030\001 \001(\010\"@\n\007Payload\022\'\n\004type\030\001 " +
|
"ing\"\032\n\tBoolValue\022\r\n\005value\030\001 \001(\010\"@\n\007Paylo" +
|
||||||
"\001(\0162\031.grpc.testing.PayloadType\022\014\n\004body\030\002" +
|
"ad\022\'\n\004type\030\001 \001(\0162\031.grpc.testing.PayloadT" +
|
||||||
" \001(\014\"+\n\nEchoStatus\022\014\n\004code\030\001 \001(\005\022\017\n\007mess" +
|
"ype\022\014\n\004body\030\002 \001(\014\"+\n\nEchoStatus\022\014\n\004code\030" +
|
||||||
"age\030\002 \001(\t\"\316\002\n\rSimpleRequest\0220\n\rresponse_" +
|
"\001 \001(\005\022\017\n\007message\030\002 \001(\t\"\316\002\n\rSimpleRequest" +
|
||||||
"type\030\001 \001(\0162\031.grpc.testing.PayloadType\022\025\n" +
|
|
||||||
"\rresponse_size\030\002 \001(\005\022&\n\007payload\030\003 \001(\0132\025." +
|
|
||||||
"grpc.testing.Payload\022\025\n\rfill_username\030\004 " +
|
|
||||||
"\001(\010\022\030\n\020fill_oauth_scope\030\005 \001(\010\0224\n\023respons" +
|
|
||||||
"e_compressed\030\006 \001(\0132\027.grpc.testing.BoolVa" +
|
|
||||||
"lue\0221\n\017response_status\030\007 \001(\0132\030.grpc.test" +
|
|
||||||
"ing.EchoStatus\0222\n\021expect_compressed\030\010 \001(" +
|
|
||||||
"\0132\027.grpc.testing.BoolValue\"_\n\016SimpleResp" +
|
|
||||||
"onse\022&\n\007payload\030\001 \001(\0132\025.grpc.testing.Pay" +
|
|
||||||
"load\022\020\n\010username\030\002 \001(\t\022\023\n\013oauth_scope\030\003 " +
|
|
||||||
"\001(\t\"w\n\031StreamingInputCallRequest\022&\n\007payl" +
|
|
||||||
"oad\030\001 \001(\0132\025.grpc.testing.Payload\0222\n\021expe" +
|
|
||||||
"ct_compressed\030\002 \001(\0132\027.grpc.testing.BoolV" +
|
|
||||||
"alue\"=\n\032StreamingInputCallResponse\022\037\n\027ag" +
|
|
||||||
"gregated_payload_size\030\001 \001(\005\"d\n\022ResponseP" +
|
|
||||||
"arameters\022\014\n\004size\030\001 \001(\005\022\023\n\013interval_us\030\002" +
|
|
||||||
" \001(\005\022+\n\ncompressed\030\003 \001(\0132\027.grpc.testing." +
|
|
||||||
"BoolValue\"\350\001\n\032StreamingOutputCallRequest" +
|
|
||||||
"\0220\n\rresponse_type\030\001 \001(\0162\031.grpc.testing.P" +
|
"\0220\n\rresponse_type\030\001 \001(\0162\031.grpc.testing.P" +
|
||||||
"ayloadType\022=\n\023response_parameters\030\002 \003(\0132" +
|
"ayloadType\022\025\n\rresponse_size\030\002 \001(\005\022&\n\007pay" +
|
||||||
" .grpc.testing.ResponseParameters\022&\n\007pay" +
|
"load\030\003 \001(\0132\025.grpc.testing.Payload\022\025\n\rfil" +
|
||||||
"load\030\003 \001(\0132\025.grpc.testing.Payload\0221\n\017res" +
|
"l_username\030\004 \001(\010\022\030\n\020fill_oauth_scope\030\005 \001" +
|
||||||
"ponse_status\030\007 \001(\0132\030.grpc.testing.EchoSt" +
|
"(\010\0224\n\023response_compressed\030\006 \001(\0132\027.grpc.t" +
|
||||||
"atus\"E\n\033StreamingOutputCallResponse\022&\n\007p" +
|
"esting.BoolValue\0221\n\017response_status\030\007 \001(" +
|
||||||
"ayload\030\001 \001(\0132\025.grpc.testing.Payload\"3\n\017R" +
|
"\0132\030.grpc.testing.EchoStatus\0222\n\021expect_co" +
|
||||||
"econnectParams\022 \n\030max_reconnect_backoff_" +
|
"mpressed\030\010 \001(\0132\027.grpc.testing.BoolValue\"" +
|
||||||
"ms\030\001 \001(\005\"3\n\rReconnectInfo\022\016\n\006passed\030\001 \001(" +
|
"_\n\016SimpleResponse\022&\n\007payload\030\001 \001(\0132\025.grp" +
|
||||||
"\010\022\022\n\nbackoff_ms\030\002 \003(\005*\037\n\013PayloadType\022\020\n\014" +
|
"c.testing.Payload\022\020\n\010username\030\002 \001(\t\022\023\n\013o" +
|
||||||
"COMPRESSABLE\020\000B$\n\030io.grpc.benchmarks.pro" +
|
"auth_scope\030\003 \001(\t\"w\n\031StreamingInputCallRe" +
|
||||||
"toB\010Messagesb\006proto3"
|
"quest\022&\n\007payload\030\001 \001(\0132\025.grpc.testing.Pa" +
|
||||||
|
"yload\0222\n\021expect_compressed\030\002 \001(\0132\027.grpc." +
|
||||||
|
"testing.BoolValue\"=\n\032StreamingInputCallR" +
|
||||||
|
"esponse\022\037\n\027aggregated_payload_size\030\001 \001(\005" +
|
||||||
|
"\"d\n\022ResponseParameters\022\014\n\004size\030\001 \001(\005\022\023\n\013" +
|
||||||
|
"interval_us\030\002 \001(\005\022+\n\ncompressed\030\003 \001(\0132\027." +
|
||||||
|
"grpc.testing.BoolValue\"\350\001\n\032StreamingOutp" +
|
||||||
|
"utCallRequest\0220\n\rresponse_type\030\001 \001(\0162\031.g" +
|
||||||
|
"rpc.testing.PayloadType\022=\n\023response_para" +
|
||||||
|
"meters\030\002 \003(\0132 .grpc.testing.ResponsePara" +
|
||||||
|
"meters\022&\n\007payload\030\003 \001(\0132\025.grpc.testing.P" +
|
||||||
|
"ayload\0221\n\017response_status\030\007 \001(\0132\030.grpc.t" +
|
||||||
|
"esting.EchoStatus\"E\n\033StreamingOutputCall" +
|
||||||
|
"Response\022&\n\007payload\030\001 \001(\0132\025.grpc.testing" +
|
||||||
|
".Payload\"3\n\017ReconnectParams\022 \n\030max_recon" +
|
||||||
|
"nect_backoff_ms\030\001 \001(\005\"3\n\rReconnectInfo\022\016" +
|
||||||
|
"\n\006passed\030\001 \001(\010\022\022\n\nbackoff_ms\030\002 \003(\005*\037\n\013Pa" +
|
||||||
|
"yloadType\022\020\n\014COMPRESSABLE\020\000B$\n\030io.grpc.b" +
|
||||||
|
"enchmarks.protoB\010Messagesb\006proto3"
|
||||||
};
|
};
|
||||||
com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner assigner =
|
com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner assigner =
|
||||||
new com.google.protobuf.Descriptors.FileDescriptor. InternalDescriptorAssigner() {
|
new com.google.protobuf.Descriptors.FileDescriptor. InternalDescriptorAssigner() {
|
||||||
|
|
|
||||||
|
|
@ -1,5 +1,5 @@
|
||||||
// Generated by the protocol buffer compiler. DO NOT EDIT!
|
// Generated by the protocol buffer compiler. DO NOT EDIT!
|
||||||
// source: payloads.proto
|
// source: grpc/testing/payloads.proto
|
||||||
|
|
||||||
package io.grpc.benchmarks.proto;
|
package io.grpc.benchmarks.proto;
|
||||||
|
|
||||||
|
|
@ -2577,17 +2577,17 @@ public final class Payloads {
|
||||||
descriptor;
|
descriptor;
|
||||||
static {
|
static {
|
||||||
java.lang.String[] descriptorData = {
|
java.lang.String[] descriptorData = {
|
||||||
"\n\016payloads.proto\022\014grpc.testing\"7\n\020ByteBu" +
|
"\n\033grpc/testing/payloads.proto\022\014grpc.test" +
|
||||||
"fferParams\022\020\n\010req_size\030\001 \001(\005\022\021\n\tresp_siz" +
|
"ing\"7\n\020ByteBufferParams\022\020\n\010req_size\030\001 \001(" +
|
||||||
"e\030\002 \001(\005\"8\n\021SimpleProtoParams\022\020\n\010req_size" +
|
"\005\022\021\n\tresp_size\030\002 \001(\005\"8\n\021SimpleProtoParam" +
|
||||||
"\030\001 \001(\005\022\021\n\tresp_size\030\002 \001(\005\"\024\n\022ComplexProt" +
|
"s\022\020\n\010req_size\030\001 \001(\005\022\021\n\tresp_size\030\002 \001(\005\"\024" +
|
||||||
"oParams\"\312\001\n\rPayloadConfig\0228\n\016bytebuf_par" +
|
"\n\022ComplexProtoParams\"\312\001\n\rPayloadConfig\0228" +
|
||||||
"ams\030\001 \001(\0132\036.grpc.testing.ByteBufferParam" +
|
"\n\016bytebuf_params\030\001 \001(\0132\036.grpc.testing.By" +
|
||||||
"sH\000\0228\n\rsimple_params\030\002 \001(\0132\037.grpc.testin" +
|
"teBufferParamsH\000\0228\n\rsimple_params\030\002 \001(\0132" +
|
||||||
"g.SimpleProtoParamsH\000\022:\n\016complex_params\030" +
|
"\037.grpc.testing.SimpleProtoParamsH\000\022:\n\016co" +
|
||||||
"\003 \001(\0132 .grpc.testing.ComplexProtoParamsH" +
|
"mplex_params\030\003 \001(\0132 .grpc.testing.Comple" +
|
||||||
"\000B\t\n\007payloadB$\n\030io.grpc.benchmarks.proto" +
|
"xProtoParamsH\000B\t\n\007payloadB$\n\030io.grpc.ben" +
|
||||||
"B\010Payloadsb\006proto3"
|
"chmarks.protoB\010Payloadsb\006proto3"
|
||||||
};
|
};
|
||||||
com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner assigner =
|
com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner assigner =
|
||||||
new com.google.protobuf.Descriptors.FileDescriptor. InternalDescriptorAssigner() {
|
new com.google.protobuf.Descriptors.FileDescriptor. InternalDescriptorAssigner() {
|
||||||
|
|
|
||||||
|
|
@ -1,5 +1,5 @@
|
||||||
// Generated by the protocol buffer compiler. DO NOT EDIT!
|
// Generated by the protocol buffer compiler. DO NOT EDIT!
|
||||||
// source: services.proto
|
// source: grpc/testing/services.proto
|
||||||
|
|
||||||
package io.grpc.benchmarks.proto;
|
package io.grpc.benchmarks.proto;
|
||||||
|
|
||||||
|
|
@ -23,29 +23,30 @@ public final class Services {
|
||||||
descriptor;
|
descriptor;
|
||||||
static {
|
static {
|
||||||
java.lang.String[] descriptorData = {
|
java.lang.String[] descriptorData = {
|
||||||
"\n\016services.proto\022\014grpc.testing\032\016messages" +
|
"\n\033grpc/testing/services.proto\022\014grpc.test" +
|
||||||
".proto\032\rcontrol.proto2\246\003\n\020BenchmarkServi" +
|
"ing\032\033grpc/testing/messages.proto\032\032grpc/t" +
|
||||||
"ce\022F\n\tUnaryCall\022\033.grpc.testing.SimpleReq" +
|
"esting/control.proto2\246\003\n\020BenchmarkServic" +
|
||||||
"uest\032\034.grpc.testing.SimpleResponse\022N\n\rSt" +
|
"e\022F\n\tUnaryCall\022\033.grpc.testing.SimpleRequ" +
|
||||||
"reamingCall\022\033.grpc.testing.SimpleRequest" +
|
"est\032\034.grpc.testing.SimpleResponse\022N\n\rStr" +
|
||||||
"\032\034.grpc.testing.SimpleResponse(\0010\001\022R\n\023St" +
|
"eamingCall\022\033.grpc.testing.SimpleRequest\032" +
|
||||||
"reamingFromClient\022\033.grpc.testing.SimpleR" +
|
"\034.grpc.testing.SimpleResponse(\0010\001\022R\n\023Str" +
|
||||||
"equest\032\034.grpc.testing.SimpleResponse(\001\022R" +
|
"eamingFromClient\022\033.grpc.testing.SimpleRe" +
|
||||||
"\n\023StreamingFromServer\022\033.grpc.testing.Sim" +
|
"quest\032\034.grpc.testing.SimpleResponse(\001\022R\n" +
|
||||||
"pleRequest\032\034.grpc.testing.SimpleResponse" +
|
"\023StreamingFromServer\022\033.grpc.testing.Simp" +
|
||||||
"0\001\022R\n\021StreamingBothWays\022\033.grpc.testing.S" +
|
"leRequest\032\034.grpc.testing.SimpleResponse0" +
|
||||||
"impleRequest\032\034.grpc.testing.SimpleRespon" +
|
"\001\022R\n\021StreamingBothWays\022\033.grpc.testing.Si" +
|
||||||
"se(\0010\0012\227\002\n\rWorkerService\022E\n\tRunServer\022\030." +
|
"mpleRequest\032\034.grpc.testing.SimpleRespons" +
|
||||||
"grpc.testing.ServerArgs\032\032.grpc.testing.S" +
|
"e(\0010\0012\227\002\n\rWorkerService\022E\n\tRunServer\022\030.g" +
|
||||||
"erverStatus(\0010\001\022E\n\tRunClient\022\030.grpc.test" +
|
"rpc.testing.ServerArgs\032\032.grpc.testing.Se" +
|
||||||
"ing.ClientArgs\032\032.grpc.testing.ClientStat" +
|
"rverStatus(\0010\001\022E\n\tRunClient\022\030.grpc.testi" +
|
||||||
"us(\0010\001\022B\n\tCoreCount\022\031.grpc.testing.CoreR" +
|
"ng.ClientArgs\032\032.grpc.testing.ClientStatu" +
|
||||||
"equest\032\032.grpc.testing.CoreResponse\0224\n\nQu" +
|
"s(\0010\001\022B\n\tCoreCount\022\031.grpc.testing.CoreRe" +
|
||||||
"itWorker\022\022.grpc.testing.Void\032\022.grpc.test" +
|
"quest\032\032.grpc.testing.CoreResponse\0224\n\nQui" +
|
||||||
"ing.Void2^\n\030ReportQpsScenarioService\022B\n\016" +
|
"tWorker\022\022.grpc.testing.Void\032\022.grpc.testi" +
|
||||||
"ReportScenario\022\034.grpc.testing.ScenarioRe" +
|
"ng.Void2^\n\030ReportQpsScenarioService\022B\n\016R" +
|
||||||
"sult\032\022.grpc.testing.VoidB$\n\030io.grpc.benc" +
|
"eportScenario\022\034.grpc.testing.ScenarioRes" +
|
||||||
"hmarks.protoB\010Servicesb\006proto3"
|
"ult\032\022.grpc.testing.VoidB$\n\030io.grpc.bench" +
|
||||||
|
"marks.protoB\010Servicesb\006proto3"
|
||||||
};
|
};
|
||||||
com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner assigner =
|
com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner assigner =
|
||||||
new com.google.protobuf.Descriptors.FileDescriptor. InternalDescriptorAssigner() {
|
new com.google.protobuf.Descriptors.FileDescriptor. InternalDescriptorAssigner() {
|
||||||
|
|
|
||||||
|
|
@ -1,5 +1,5 @@
|
||||||
// Generated by the protocol buffer compiler. DO NOT EDIT!
|
// Generated by the protocol buffer compiler. DO NOT EDIT!
|
||||||
// source: stats.proto
|
// source: grpc/testing/stats.proto
|
||||||
|
|
||||||
package io.grpc.benchmarks.proto;
|
package io.grpc.benchmarks.proto;
|
||||||
|
|
||||||
|
|
@ -4365,23 +4365,23 @@ public final class Stats {
|
||||||
descriptor;
|
descriptor;
|
||||||
static {
|
static {
|
||||||
java.lang.String[] descriptorData = {
|
java.lang.String[] descriptorData = {
|
||||||
"\n\013stats.proto\022\014grpc.testing\"\221\001\n\013ServerSt" +
|
"\n\030grpc/testing/stats.proto\022\014grpc.testing" +
|
||||||
"ats\022\024\n\014time_elapsed\030\001 \001(\001\022\021\n\ttime_user\030\002" +
|
"\"\221\001\n\013ServerStats\022\024\n\014time_elapsed\030\001 \001(\001\022\021" +
|
||||||
" \001(\001\022\023\n\013time_system\030\003 \001(\001\022\026\n\016total_cpu_t" +
|
"\n\ttime_user\030\002 \001(\001\022\023\n\013time_system\030\003 \001(\001\022\026" +
|
||||||
"ime\030\004 \001(\004\022\025\n\ridle_cpu_time\030\005 \001(\004\022\025\n\rcq_p" +
|
"\n\016total_cpu_time\030\004 \001(\004\022\025\n\ridle_cpu_time\030" +
|
||||||
"oll_count\030\006 \001(\004\";\n\017HistogramParams\022\022\n\nre" +
|
"\005 \001(\004\022\025\n\rcq_poll_count\030\006 \001(\004\";\n\017Histogra" +
|
||||||
"solution\030\001 \001(\001\022\024\n\014max_possible\030\002 \001(\001\"w\n\r" +
|
"mParams\022\022\n\nresolution\030\001 \001(\001\022\024\n\014max_possi" +
|
||||||
"HistogramData\022\016\n\006bucket\030\001 \003(\r\022\020\n\010min_see" +
|
"ble\030\002 \001(\001\"w\n\rHistogramData\022\016\n\006bucket\030\001 \003" +
|
||||||
"n\030\002 \001(\001\022\020\n\010max_seen\030\003 \001(\001\022\013\n\003sum\030\004 \001(\001\022\026" +
|
"(\r\022\020\n\010min_seen\030\002 \001(\001\022\020\n\010max_seen\030\003 \001(\001\022\013" +
|
||||||
"\n\016sum_of_squares\030\005 \001(\001\022\r\n\005count\030\006 \001(\001\"8\n" +
|
"\n\003sum\030\004 \001(\001\022\026\n\016sum_of_squares\030\005 \001(\001\022\r\n\005c" +
|
||||||
"\022RequestResultCount\022\023\n\013status_code\030\001 \001(\005" +
|
"ount\030\006 \001(\001\"8\n\022RequestResultCount\022\023\n\013stat" +
|
||||||
"\022\r\n\005count\030\002 \001(\003\"\315\001\n\013ClientStats\022.\n\tlaten" +
|
"us_code\030\001 \001(\005\022\r\n\005count\030\002 \001(\003\"\315\001\n\013ClientS" +
|
||||||
"cies\030\001 \001(\0132\033.grpc.testing.HistogramData\022" +
|
"tats\022.\n\tlatencies\030\001 \001(\0132\033.grpc.testing.H" +
|
||||||
"\024\n\014time_elapsed\030\002 \001(\001\022\021\n\ttime_user\030\003 \001(\001" +
|
"istogramData\022\024\n\014time_elapsed\030\002 \001(\001\022\021\n\tti" +
|
||||||
"\022\023\n\013time_system\030\004 \001(\001\0229\n\017request_results" +
|
"me_user\030\003 \001(\001\022\023\n\013time_system\030\004 \001(\001\0229\n\017re" +
|
||||||
"\030\005 \003(\0132 .grpc.testing.RequestResultCount" +
|
"quest_results\030\005 \003(\0132 .grpc.testing.Reque" +
|
||||||
"\022\025\n\rcq_poll_count\030\006 \001(\004B!\n\030io.grpc.bench" +
|
"stResultCount\022\025\n\rcq_poll_count\030\006 \001(\004B!\n\030" +
|
||||||
"marks.protoB\005Statsb\006proto3"
|
"io.grpc.benchmarks.protoB\005Statsb\006proto3"
|
||||||
};
|
};
|
||||||
com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner assigner =
|
com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner assigner =
|
||||||
new com.google.protobuf.Descriptors.FileDescriptor. InternalDescriptorAssigner() {
|
new com.google.protobuf.Descriptors.FileDescriptor. InternalDescriptorAssigner() {
|
||||||
|
|
|
||||||
|
|
@ -14,8 +14,8 @@
|
||||||
// limitations under the License.
|
// limitations under the License.
|
||||||
syntax = "proto3";
|
syntax = "proto3";
|
||||||
|
|
||||||
import "payloads.proto";
|
import "grpc/testing/payloads.proto";
|
||||||
import "stats.proto";
|
import "grpc/testing/stats.proto";
|
||||||
|
|
||||||
package grpc.testing;
|
package grpc.testing;
|
||||||
|
|
||||||
|
|
@ -16,8 +16,8 @@
|
||||||
// of unary/streaming requests/responses.
|
// of unary/streaming requests/responses.
|
||||||
syntax = "proto3";
|
syntax = "proto3";
|
||||||
|
|
||||||
import "messages.proto";
|
import "grpc/testing/messages.proto";
|
||||||
import "control.proto";
|
import "grpc/testing/control.proto";
|
||||||
|
|
||||||
package grpc.testing;
|
package grpc.testing;
|
||||||
|
|
||||||
Loading…
Reference in New Issue