flasn4nt
/
grpc-java
mirror of https://github.com/grpc/grpc-java.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

services: update monitoring.proto

This commit is contained in:
Eric Gribkoff 2017-03-21 10:46:40 -07:00 committed by GitHub
parent 00bebc477a
commit 260fc273b8
10 changed files with 2345 additions and 1689 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2010
services/src/generated/main/java/io/grpc/instrumentation/v1alpha/CanonicalRpcStats.java
View File

File diff suppressed because it is too large Load Diff

170
services/src/generated/main/java/io/grpc/instrumentation/v1alpha/CanonicalRpcStatsOrBuilder.java
View File

@ -8,219 +8,219 @@ public interface CanonicalRpcStatsOrBuilder extends
com.google.protobuf.MessageOrBuilder {
/**
* <code>.grpc.instrumentation.v1alpha.CanonicalRpcStats.View rpc_client_errors = 1;</code>
* <code>.grpc.instrumentation.v1alpha.StatsResponse rpc_client_errors = 1;</code>
*/
boolean hasRpcClientErrors();
/**
* <code>.grpc.instrumentation.v1alpha.CanonicalRpcStats.View rpc_client_errors = 1;</code>
* <code>.grpc.instrumentation.v1alpha.StatsResponse rpc_client_errors = 1;</code>
*/
io.grpc.instrumentation.v1alpha.CanonicalRpcStats.View getRpcClientErrors();
io.grpc.instrumentation.v1alpha.StatsResponse getRpcClientErrors();
/**
* <code>.grpc.instrumentation.v1alpha.CanonicalRpcStats.View rpc_client_errors = 1;</code>
* <code>.grpc.instrumentation.v1alpha.StatsResponse rpc_client_errors = 1;</code>
*/
io.grpc.instrumentation.v1alpha.CanonicalRpcStats.ViewOrBuilder getRpcClientErrorsOrBuilder();
io.grpc.instrumentation.v1alpha.StatsResponseOrBuilder getRpcClientErrorsOrBuilder();
/**
* <code>.grpc.instrumentation.v1alpha.CanonicalRpcStats.View rpc_client_completed_rpcs = 2;</code>
* <code>.grpc.instrumentation.v1alpha.StatsResponse rpc_client_completed_rpcs = 2;</code>
*/
boolean hasRpcClientCompletedRpcs();
/**
* <code>.grpc.instrumentation.v1alpha.CanonicalRpcStats.View rpc_client_completed_rpcs = 2;</code>
* <code>.grpc.instrumentation.v1alpha.StatsResponse rpc_client_completed_rpcs = 2;</code>
*/
io.grpc.instrumentation.v1alpha.CanonicalRpcStats.View getRpcClientCompletedRpcs();
io.grpc.instrumentation.v1alpha.StatsResponse getRpcClientCompletedRpcs();
/**
* <code>.grpc.instrumentation.v1alpha.CanonicalRpcStats.View rpc_client_completed_rpcs = 2;</code>
* <code>.grpc.instrumentation.v1alpha.StatsResponse rpc_client_completed_rpcs = 2;</code>
*/
io.grpc.instrumentation.v1alpha.CanonicalRpcStats.ViewOrBuilder getRpcClientCompletedRpcsOrBuilder();
io.grpc.instrumentation.v1alpha.StatsResponseOrBuilder getRpcClientCompletedRpcsOrBuilder();
/**
* <code>.grpc.instrumentation.v1alpha.CanonicalRpcStats.View rpc_client_started_rpcs = 3;</code>
* <code>.grpc.instrumentation.v1alpha.StatsResponse rpc_client_started_rpcs = 3;</code>
*/
boolean hasRpcClientStartedRpcs();
/**
* <code>.grpc.instrumentation.v1alpha.CanonicalRpcStats.View rpc_client_started_rpcs = 3;</code>
* <code>.grpc.instrumentation.v1alpha.StatsResponse rpc_client_started_rpcs = 3;</code>
*/
io.grpc.instrumentation.v1alpha.CanonicalRpcStats.View getRpcClientStartedRpcs();
io.grpc.instrumentation.v1alpha.StatsResponse getRpcClientStartedRpcs();
/**
* <code>.grpc.instrumentation.v1alpha.CanonicalRpcStats.View rpc_client_started_rpcs = 3;</code>
* <code>.grpc.instrumentation.v1alpha.StatsResponse rpc_client_started_rpcs = 3;</code>
*/
io.grpc.instrumentation.v1alpha.CanonicalRpcStats.ViewOrBuilder getRpcClientStartedRpcsOrBuilder();
io.grpc.instrumentation.v1alpha.StatsResponseOrBuilder getRpcClientStartedRpcsOrBuilder();
/**
* <code>.grpc.instrumentation.v1alpha.CanonicalRpcStats.View rpc_client_elapsed_time = 4;</code>
* <code>.grpc.instrumentation.v1alpha.StatsResponse rpc_client_elapsed_time = 4;</code>
*/
boolean hasRpcClientElapsedTime();
/**
* <code>.grpc.instrumentation.v1alpha.CanonicalRpcStats.View rpc_client_elapsed_time = 4;</code>
* <code>.grpc.instrumentation.v1alpha.StatsResponse rpc_client_elapsed_time = 4;</code>
*/
io.grpc.instrumentation.v1alpha.CanonicalRpcStats.View getRpcClientElapsedTime();
io.grpc.instrumentation.v1alpha.StatsResponse getRpcClientElapsedTime();
/**
* <code>.grpc.instrumentation.v1alpha.CanonicalRpcStats.View rpc_client_elapsed_time = 4;</code>
* <code>.grpc.instrumentation.v1alpha.StatsResponse rpc_client_elapsed_time = 4;</code>
*/
io.grpc.instrumentation.v1alpha.CanonicalRpcStats.ViewOrBuilder getRpcClientElapsedTimeOrBuilder();
io.grpc.instrumentation.v1alpha.StatsResponseOrBuilder getRpcClientElapsedTimeOrBuilder();
/**
* <code>.grpc.instrumentation.v1alpha.CanonicalRpcStats.View rpc_client_server_elapsed_time = 5;</code>
* <code>.grpc.instrumentation.v1alpha.StatsResponse rpc_client_server_elapsed_time = 5;</code>
*/
boolean hasRpcClientServerElapsedTime();
/**
* <code>.grpc.instrumentation.v1alpha.CanonicalRpcStats.View rpc_client_server_elapsed_time = 5;</code>
* <code>.grpc.instrumentation.v1alpha.StatsResponse rpc_client_server_elapsed_time = 5;</code>
*/
io.grpc.instrumentation.v1alpha.CanonicalRpcStats.View getRpcClientServerElapsedTime();
io.grpc.instrumentation.v1alpha.StatsResponse getRpcClientServerElapsedTime();
/**
* <code>.grpc.instrumentation.v1alpha.CanonicalRpcStats.View rpc_client_server_elapsed_time = 5;</code>
* <code>.grpc.instrumentation.v1alpha.StatsResponse rpc_client_server_elapsed_time = 5;</code>
*/
io.grpc.instrumentation.v1alpha.CanonicalRpcStats.ViewOrBuilder getRpcClientServerElapsedTimeOrBuilder();
io.grpc.instrumentation.v1alpha.StatsResponseOrBuilder getRpcClientServerElapsedTimeOrBuilder();
/**
* <code>.grpc.instrumentation.v1alpha.CanonicalRpcStats.View rpc_client_request_bytes = 6;</code>
* <code>.grpc.instrumentation.v1alpha.StatsResponse rpc_client_request_bytes = 6;</code>
*/
boolean hasRpcClientRequestBytes();
/**
* <code>.grpc.instrumentation.v1alpha.CanonicalRpcStats.View rpc_client_request_bytes = 6;</code>
* <code>.grpc.instrumentation.v1alpha.StatsResponse rpc_client_request_bytes = 6;</code>
*/
io.grpc.instrumentation.v1alpha.CanonicalRpcStats.View getRpcClientRequestBytes();
io.grpc.instrumentation.v1alpha.StatsResponse getRpcClientRequestBytes();
/**
* <code>.grpc.instrumentation.v1alpha.CanonicalRpcStats.View rpc_client_request_bytes = 6;</code>
* <code>.grpc.instrumentation.v1alpha.StatsResponse rpc_client_request_bytes = 6;</code>
*/
io.grpc.instrumentation.v1alpha.CanonicalRpcStats.ViewOrBuilder getRpcClientRequestBytesOrBuilder();
io.grpc.instrumentation.v1alpha.StatsResponseOrBuilder getRpcClientRequestBytesOrBuilder();
/**
* <code>.grpc.instrumentation.v1alpha.CanonicalRpcStats.View rpc_client_response_bytes = 7;</code>
* <code>.grpc.instrumentation.v1alpha.StatsResponse rpc_client_response_bytes = 7;</code>
*/
boolean hasRpcClientResponseBytes();
/**
* <code>.grpc.instrumentation.v1alpha.CanonicalRpcStats.View rpc_client_response_bytes = 7;</code>
* <code>.grpc.instrumentation.v1alpha.StatsResponse rpc_client_response_bytes = 7;</code>
*/
io.grpc.instrumentation.v1alpha.CanonicalRpcStats.View getRpcClientResponseBytes();
io.grpc.instrumentation.v1alpha.StatsResponse getRpcClientResponseBytes();
/**
* <code>.grpc.instrumentation.v1alpha.CanonicalRpcStats.View rpc_client_response_bytes = 7;</code>
* <code>.grpc.instrumentation.v1alpha.StatsResponse rpc_client_response_bytes = 7;</code>
*/
io.grpc.instrumentation.v1alpha.CanonicalRpcStats.ViewOrBuilder getRpcClientResponseBytesOrBuilder();
io.grpc.instrumentation.v1alpha.StatsResponseOrBuilder getRpcClientResponseBytesOrBuilder();
/**
* <code>.grpc.instrumentation.v1alpha.CanonicalRpcStats.View rpc_client_request_count = 8;</code>
* <code>.grpc.instrumentation.v1alpha.StatsResponse rpc_client_request_count = 8;</code>
*/
boolean hasRpcClientRequestCount();
/**
* <code>.grpc.instrumentation.v1alpha.CanonicalRpcStats.View rpc_client_request_count = 8;</code>
* <code>.grpc.instrumentation.v1alpha.StatsResponse rpc_client_request_count = 8;</code>
*/
io.grpc.instrumentation.v1alpha.CanonicalRpcStats.View getRpcClientRequestCount();
io.grpc.instrumentation.v1alpha.StatsResponse getRpcClientRequestCount();
/**
* <code>.grpc.instrumentation.v1alpha.CanonicalRpcStats.View rpc_client_request_count = 8;</code>
* <code>.grpc.instrumentation.v1alpha.StatsResponse rpc_client_request_count = 8;</code>
*/
io.grpc.instrumentation.v1alpha.CanonicalRpcStats.ViewOrBuilder getRpcClientRequestCountOrBuilder();
io.grpc.instrumentation.v1alpha.StatsResponseOrBuilder getRpcClientRequestCountOrBuilder();
/**
* <code>.grpc.instrumentation.v1alpha.CanonicalRpcStats.View rpc_client_response_count = 9;</code>
* <code>.grpc.instrumentation.v1alpha.StatsResponse rpc_client_response_count = 9;</code>
*/
boolean hasRpcClientResponseCount();
/**
* <code>.grpc.instrumentation.v1alpha.CanonicalRpcStats.View rpc_client_response_count = 9;</code>
* <code>.grpc.instrumentation.v1alpha.StatsResponse rpc_client_response_count = 9;</code>
*/
io.grpc.instrumentation.v1alpha.CanonicalRpcStats.View getRpcClientResponseCount();
io.grpc.instrumentation.v1alpha.StatsResponse getRpcClientResponseCount();
/**
* <code>.grpc.instrumentation.v1alpha.CanonicalRpcStats.View rpc_client_response_count = 9;</code>
* <code>.grpc.instrumentation.v1alpha.StatsResponse rpc_client_response_count = 9;</code>
*/
io.grpc.instrumentation.v1alpha.CanonicalRpcStats.ViewOrBuilder getRpcClientResponseCountOrBuilder();
io.grpc.instrumentation.v1alpha.StatsResponseOrBuilder getRpcClientResponseCountOrBuilder();
/**
* <code>.grpc.instrumentation.v1alpha.CanonicalRpcStats.View rpc_server_errors = 10;</code>
* <code>.grpc.instrumentation.v1alpha.StatsResponse rpc_server_errors = 10;</code>
*/
boolean hasRpcServerErrors();
/**
* <code>.grpc.instrumentation.v1alpha.CanonicalRpcStats.View rpc_server_errors = 10;</code>
* <code>.grpc.instrumentation.v1alpha.StatsResponse rpc_server_errors = 10;</code>
*/
io.grpc.instrumentation.v1alpha.CanonicalRpcStats.View getRpcServerErrors();
io.grpc.instrumentation.v1alpha.StatsResponse getRpcServerErrors();
/**
* <code>.grpc.instrumentation.v1alpha.CanonicalRpcStats.View rpc_server_errors = 10;</code>
* <code>.grpc.instrumentation.v1alpha.StatsResponse rpc_server_errors = 10;</code>
*/
io.grpc.instrumentation.v1alpha.CanonicalRpcStats.ViewOrBuilder getRpcServerErrorsOrBuilder();
io.grpc.instrumentation.v1alpha.StatsResponseOrBuilder getRpcServerErrorsOrBuilder();
/**
* <code>.grpc.instrumentation.v1alpha.CanonicalRpcStats.View rpc_server_completed_rpcs = 11;</code>
* <code>.grpc.instrumentation.v1alpha.StatsResponse rpc_server_completed_rpcs = 11;</code>
*/
boolean hasRpcServerCompletedRpcs();
/**
* <code>.grpc.instrumentation.v1alpha.CanonicalRpcStats.View rpc_server_completed_rpcs = 11;</code>
* <code>.grpc.instrumentation.v1alpha.StatsResponse rpc_server_completed_rpcs = 11;</code>
*/
io.grpc.instrumentation.v1alpha.CanonicalRpcStats.View getRpcServerCompletedRpcs();
io.grpc.instrumentation.v1alpha.StatsResponse getRpcServerCompletedRpcs();
/**
* <code>.grpc.instrumentation.v1alpha.CanonicalRpcStats.View rpc_server_completed_rpcs = 11;</code>
* <code>.grpc.instrumentation.v1alpha.StatsResponse rpc_server_completed_rpcs = 11;</code>
*/
io.grpc.instrumentation.v1alpha.CanonicalRpcStats.ViewOrBuilder getRpcServerCompletedRpcsOrBuilder();
io.grpc.instrumentation.v1alpha.StatsResponseOrBuilder getRpcServerCompletedRpcsOrBuilder();
/**
* <code>.grpc.instrumentation.v1alpha.CanonicalRpcStats.View rpc_server_server_elapsed_time = 12;</code>
* <code>.grpc.instrumentation.v1alpha.StatsResponse rpc_server_server_elapsed_time = 12;</code>
*/
boolean hasRpcServerServerElapsedTime();
/**
* <code>.grpc.instrumentation.v1alpha.CanonicalRpcStats.View rpc_server_server_elapsed_time = 12;</code>
* <code>.grpc.instrumentation.v1alpha.StatsResponse rpc_server_server_elapsed_time = 12;</code>
*/
io.grpc.instrumentation.v1alpha.CanonicalRpcStats.View getRpcServerServerElapsedTime();
io.grpc.instrumentation.v1alpha.StatsResponse getRpcServerServerElapsedTime();
/**
* <code>.grpc.instrumentation.v1alpha.CanonicalRpcStats.View rpc_server_server_elapsed_time = 12;</code>
* <code>.grpc.instrumentation.v1alpha.StatsResponse rpc_server_server_elapsed_time = 12;</code>
*/
io.grpc.instrumentation.v1alpha.CanonicalRpcStats.ViewOrBuilder getRpcServerServerElapsedTimeOrBuilder();
io.grpc.instrumentation.v1alpha.StatsResponseOrBuilder getRpcServerServerElapsedTimeOrBuilder();
/**
* <code>.grpc.instrumentation.v1alpha.CanonicalRpcStats.View rpc_server_request_bytes = 13;</code>
* <code>.grpc.instrumentation.v1alpha.StatsResponse rpc_server_request_bytes = 13;</code>
*/
boolean hasRpcServerRequestBytes();
/**
* <code>.grpc.instrumentation.v1alpha.CanonicalRpcStats.View rpc_server_request_bytes = 13;</code>
* <code>.grpc.instrumentation.v1alpha.StatsResponse rpc_server_request_bytes = 13;</code>
*/
io.grpc.instrumentation.v1alpha.CanonicalRpcStats.View getRpcServerRequestBytes();
io.grpc.instrumentation.v1alpha.StatsResponse getRpcServerRequestBytes();
/**
* <code>.grpc.instrumentation.v1alpha.CanonicalRpcStats.View rpc_server_request_bytes = 13;</code>
* <code>.grpc.instrumentation.v1alpha.StatsResponse rpc_server_request_bytes = 13;</code>
*/
io.grpc.instrumentation.v1alpha.CanonicalRpcStats.ViewOrBuilder getRpcServerRequestBytesOrBuilder();
io.grpc.instrumentation.v1alpha.StatsResponseOrBuilder getRpcServerRequestBytesOrBuilder();
/**
* <code>.grpc.instrumentation.v1alpha.CanonicalRpcStats.View rpc_server_response_bytes = 14;</code>
* <code>.grpc.instrumentation.v1alpha.StatsResponse rpc_server_response_bytes = 14;</code>
*/
boolean hasRpcServerResponseBytes();
/**
* <code>.grpc.instrumentation.v1alpha.CanonicalRpcStats.View rpc_server_response_bytes = 14;</code>
* <code>.grpc.instrumentation.v1alpha.StatsResponse rpc_server_response_bytes = 14;</code>
*/
io.grpc.instrumentation.v1alpha.CanonicalRpcStats.View getRpcServerResponseBytes();
io.grpc.instrumentation.v1alpha.StatsResponse getRpcServerResponseBytes();
/**
* <code>.grpc.instrumentation.v1alpha.CanonicalRpcStats.View rpc_server_response_bytes = 14;</code>
* <code>.grpc.instrumentation.v1alpha.StatsResponse rpc_server_response_bytes = 14;</code>
*/
io.grpc.instrumentation.v1alpha.CanonicalRpcStats.ViewOrBuilder getRpcServerResponseBytesOrBuilder();
io.grpc.instrumentation.v1alpha.StatsResponseOrBuilder getRpcServerResponseBytesOrBuilder();
/**
* <code>.grpc.instrumentation.v1alpha.CanonicalRpcStats.View rpc_server_request_count = 15;</code>
* <code>.grpc.instrumentation.v1alpha.StatsResponse rpc_server_request_count = 15;</code>
*/
boolean hasRpcServerRequestCount();
/**
* <code>.grpc.instrumentation.v1alpha.CanonicalRpcStats.View rpc_server_request_count = 15;</code>
* <code>.grpc.instrumentation.v1alpha.StatsResponse rpc_server_request_count = 15;</code>
*/
io.grpc.instrumentation.v1alpha.CanonicalRpcStats.View getRpcServerRequestCount();
io.grpc.instrumentation.v1alpha.StatsResponse getRpcServerRequestCount();
/**
* <code>.grpc.instrumentation.v1alpha.CanonicalRpcStats.View rpc_server_request_count = 15;</code>
* <code>.grpc.instrumentation.v1alpha.StatsResponse rpc_server_request_count = 15;</code>
*/
io.grpc.instrumentation.v1alpha.CanonicalRpcStats.ViewOrBuilder getRpcServerRequestCountOrBuilder();
io.grpc.instrumentation.v1alpha.StatsResponseOrBuilder getRpcServerRequestCountOrBuilder();
/**
* <code>.grpc.instrumentation.v1alpha.CanonicalRpcStats.View rpc_server_response_count = 16;</code>
* <code>.grpc.instrumentation.v1alpha.StatsResponse rpc_server_response_count = 16;</code>
*/
boolean hasRpcServerResponseCount();
/**
* <code>.grpc.instrumentation.v1alpha.CanonicalRpcStats.View rpc_server_response_count = 16;</code>
* <code>.grpc.instrumentation.v1alpha.StatsResponse rpc_server_response_count = 16;</code>
*/
io.grpc.instrumentation.v1alpha.CanonicalRpcStats.View getRpcServerResponseCount();
io.grpc.instrumentation.v1alpha.StatsResponse getRpcServerResponseCount();
/**
* <code>.grpc.instrumentation.v1alpha.CanonicalRpcStats.View rpc_server_response_count = 16;</code>
* <code>.grpc.instrumentation.v1alpha.StatsResponse rpc_server_response_count = 16;</code>
*/
io.grpc.instrumentation.v1alpha.CanonicalRpcStats.ViewOrBuilder getRpcServerResponseCountOrBuilder();
io.grpc.instrumentation.v1alpha.StatsResponseOrBuilder getRpcServerResponseCountOrBuilder();
/**
* <pre>
*TODO(ericgribkoff) Add minute-hour interval stats.
* </pre>
*
* <code>.grpc.instrumentation.v1alpha.CanonicalRpcStats.View rpc_server_elapsed_time = 17;</code>
* <code>.grpc.instrumentation.v1alpha.StatsResponse rpc_server_elapsed_time = 17;</code>
*/
boolean hasRpcServerElapsedTime();
/**
@ -228,15 +228,15 @@ public interface CanonicalRpcStatsOrBuilder extends
*TODO(ericgribkoff) Add minute-hour interval stats.
* </pre>
*
* <code>.grpc.instrumentation.v1alpha.CanonicalRpcStats.View rpc_server_elapsed_time = 17;</code>
* <code>.grpc.instrumentation.v1alpha.StatsResponse rpc_server_elapsed_time = 17;</code>
*/
io.grpc.instrumentation.v1alpha.CanonicalRpcStats.View getRpcServerElapsedTime();
io.grpc.instrumentation.v1alpha.StatsResponse getRpcServerElapsedTime();
/**
* <pre>
*TODO(ericgribkoff) Add minute-hour interval stats.
* </pre>
*
* <code>.grpc.instrumentation.v1alpha.CanonicalRpcStats.View rpc_server_elapsed_time = 17;</code>
* <code>.grpc.instrumentation.v1alpha.StatsResponse rpc_server_elapsed_time = 17;</code>
*/
io.grpc.instrumentation.v1alpha.CanonicalRpcStats.ViewOrBuilder getRpcServerElapsedTimeOrBuilder();
io.grpc.instrumentation.v1alpha.StatsResponseOrBuilder getRpcServerElapsedTimeOrBuilder();
}

141
services/src/generated/main/java/io/grpc/instrumentation/v1alpha/MonitoringProto.java
View File

@ -19,11 +19,6 @@ public final class MonitoringProto {
static final
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
internal_static_grpc_instrumentation_v1alpha_CanonicalRpcStats_fieldAccessorTable;
static final com.google.protobuf.Descriptors.Descriptor
internal_static_grpc_instrumentation_v1alpha_CanonicalRpcStats_View_descriptor;
static final
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
internal_static_grpc_instrumentation_v1alpha_CanonicalRpcStats_View_fieldAccessorTable;
static final com.google.protobuf.Descriptors.Descriptor
internal_static_grpc_instrumentation_v1alpha_StatsRequest_descriptor;
static final
@ -67,70 +62,68 @@ public final class MonitoringProto {
"g.proto\022\034grpc.instrumentation.v1alpha\032#g" +
"oogle/instrumentation/census.proto\032\031goog" +
"le/protobuf/any.proto\032\033google/protobuf/e" +
"mpty.proto\"\261\r\n\021CanonicalRpcStats\022O\n\021rpc_" +
"client_errors\030\001 \001(\01324.grpc.instrumentati" +
"on.v1alpha.CanonicalRpcStats.View\022W\n\031rpc" +
"_client_completed_rpcs\030\002 \001(\01324.grpc.inst" +
"rumentation.v1alpha.CanonicalRpcStats.Vi" +
"ew\022U\n\027rpc_client_started_rpcs\030\003 \001(\01324.gr",
"pc.instrumentation.v1alpha.CanonicalRpcS" +
"tats.View\022U\n\027rpc_client_elapsed_time\030\004 \001" +
"(\01324.grpc.instrumentation.v1alpha.Canoni" +
"calRpcStats.View\022\\\n\036rpc_client_server_el" +
"apsed_time\030\005 \001(\01324.grpc.instrumentation." +
"v1alpha.CanonicalRpcStats.View\022V\n\030rpc_cl" +
"ient_request_bytes\030\006 \001(\01324.grpc.instrume" +
"ntation.v1alpha.CanonicalRpcStats.View\022W" +
"\n\031rpc_client_response_bytes\030\007 \001(\01324.grpc" +
".instrumentation.v1alpha.CanonicalRpcSta",
"ts.View\022V\n\030rpc_client_request_count\030\010 \001(" +
"\01324.grpc.instrumentation.v1alpha.Canonic" +
"alRpcStats.View\022W\n\031rpc_client_response_c" +
"ount\030\t \001(\01324.grpc.instrumentation.v1alph" +
"a.CanonicalRpcStats.View\022O\n\021rpc_server_e" +
"rrors\030\n \001(\01324.grpc.instrumentation.v1alp" +
"ha.CanonicalRpcStats.View\022W\n\031rpc_server_" +
"completed_rpcs\030\013 \001(\01324.grpc.instrumentat" +
"ion.v1alpha.CanonicalRpcStats.View\022\\\n\036rp" +
"c_server_server_elapsed_time\030\014 \001(\01324.grp",
"c.instrumentation.v1alpha.CanonicalRpcSt" +
"ats.View\022V\n\030rpc_server_request_bytes\030\r \001" +
"(\01324.grpc.instrumentation.v1alpha.Canoni" +
"calRpcStats.View\022W\n\031rpc_server_response_" +
"bytes\030\016 \001(\01324.grpc.instrumentation.v1alp" +
"ha.CanonicalRpcStats.View\022V\n\030rpc_server_" +
"request_count\030\017 \001(\01324.grpc.instrumentati" +
"on.v1alpha.CanonicalRpcStats.View\022W\n\031rpc" +
"_server_response_count\030\020 \001(\01324.grpc.inst" +
"rumentation.v1alpha.CanonicalRpcStats.Vi",
"ew\022U\n\027rpc_server_elapsed_time\030\021 \001(\01324.gr" +
"pc.instrumentation.v1alpha.CanonicalRpcS" +
"tats.View\032\302\001\n\004View\022M\n\026measurement_descri" +
"ptor\030\001 \001(\0132-.google.instrumentation.Meas" +
"urementDescriptor\022?\n\017view_descriptor\030\002 \001" +
"(\0132&.google.instrumentation.ViewDescript" +
"or\022*\n\004view\030\003 \001(\0132\034.google.instrumentatio" +
"n.View\"\016\n\014StatsRequest\"\017\n\rStatsResponse\"" +
"\016\n\014TraceRequest\"\017\n\rTraceResponse\"#\n\023Moni" +
"toringDataGroup\022\014\n\004name\030\001 \001(\t\">\n\024CustomM",
"onitoringData\022&\n\010contents\030\001 \001(\0132\024.google" +
".protobuf.Any2\265\004\n\nMonitoring\022a\n\024GetCanon" +
"icalRpcStats\022\026.google.protobuf.Empty\032/.g" +
"rpc.instrumentation.v1alpha.CanonicalRpc" +
"Stats\"\000\022e\n\010GetStats\022*.grpc.instrumentati" +
"on.v1alpha.StatsRequest\032+.grpc.instrumen" +
"tation.v1alpha.StatsResponse\"\000\022i\n\nWatchS" +
"tats\022*.grpc.instrumentation.v1alpha.Stat" +
"sRequest\032+.grpc.instrumentation.v1alpha." +
"StatsResponse\"\0000\001\022m\n\020GetRequestTraces\022*.",
"grpc.instrumentation.v1alpha.TraceReques" +
"t\032+.grpc.instrumentation.v1alpha.TraceRe" +
"sponse\"\000\022\202\001\n\027GetCustomMonitoringData\0221.g" +
"rpc.instrumentation.v1alpha.MonitoringDa" +
"taGroup\0322.grpc.instrumentation.v1alpha.C" +
"ustomMonitoringData\"\000B4\n\037io.grpc.instrum" +
"entation.v1alphaB\017MonitoringProtoP\001b\006pro" +
"to3"
"mpty.proto\"\323\n\n\021CanonicalRpcStats\022F\n\021rpc_" +
"client_errors\030\001 \001(\0132+.grpc.instrumentati" +
"on.v1alpha.StatsResponse\022N\n\031rpc_client_c" +
"ompleted_rpcs\030\002 \001(\0132+.grpc.instrumentati" +
"on.v1alpha.StatsResponse\022L\n\027rpc_client_s" +
"tarted_rpcs\030\003 \001(\0132+.grpc.instrumentation",
".v1alpha.StatsResponse\022L\n\027rpc_client_ela" +
"psed_time\030\004 \001(\0132+.grpc.instrumentation.v" +
"1alpha.StatsResponse\022S\n\036rpc_client_serve" +
"r_elapsed_time\030\005 \001(\0132+.grpc.instrumentat" +
"ion.v1alpha.StatsResponse\022M\n\030rpc_client_" +
"request_bytes\030\006 \001(\0132+.grpc.instrumentati" +
"on.v1alpha.StatsResponse\022N\n\031rpc_client_r" +
"esponse_bytes\030\007 \001(\0132+.grpc.instrumentati" +
"on.v1alpha.StatsResponse\022M\n\030rpc_client_r" +
"equest_count\030\010 \001(\0132+.grpc.instrumentatio",
"n.v1alpha.StatsResponse\022N\n\031rpc_client_re" +
"sponse_count\030\t \001(\0132+.grpc.instrumentatio" +
"n.v1alpha.StatsResponse\022F\n\021rpc_server_er" +
"rors\030\n \001(\0132+.grpc.instrumentation.v1alph" +
"a.StatsResponse\022N\n\031rpc_server_completed_" +
"rpcs\030\013 \001(\0132+.grpc.instrumentation.v1alph" +
"a.StatsResponse\022S\n\036rpc_server_server_ela" +
"psed_time\030\014 \001(\0132+.grpc.instrumentation.v" +
"1alpha.StatsResponse\022M\n\030rpc_server_reque" +
"st_bytes\030\r \001(\0132+.grpc.instrumentation.v1",
"alpha.StatsResponse\022N\n\031rpc_server_respon" +
"se_bytes\030\016 \001(\0132+.grpc.instrumentation.v1" +
"alpha.StatsResponse\022M\n\030rpc_server_reques" +
"t_count\030\017 \001(\0132+.grpc.instrumentation.v1a" +
"lpha.StatsResponse\022N\n\031rpc_server_respons" +
"e_count\030\020 \001(\0132+.grpc.instrumentation.v1a" +
"lpha.StatsResponse\022L\n\027rpc_server_elapsed" +
"_time\030\021 \001(\0132+.grpc.instrumentation.v1alp" +
"ha.StatsResponse\"q\n\014StatsRequest\022\022\n\nview" +
"_names\030\001 \003(\t\022\031\n\021measurement_names\030\002 \003(\t\022",
"2\n*dont_include_descriptors_in_first_res" +
"ponse\030\003 \001(\010\"\313\001\n\rStatsResponse\022M\n\026measure" +
"ment_descriptor\030\001 \001(\0132-.google.instrumen" +
"tation.MeasurementDescriptor\022?\n\017view_des" +
"criptor\030\002 \001(\0132&.google.instrumentation.V" +
"iewDescriptor\022*\n\004view\030\003 \001(\0132\034.google.ins" +
"trumentation.View\"\016\n\014TraceRequest\"\017\n\rTra" +
"ceResponse\"#\n\023MonitoringDataGroup\022\014\n\004nam" +
"e\030\001 \001(\t\">\n\024CustomMonitoringData\022&\n\010conte" +
"nts\030\001 \001(\0132\024.google.protobuf.Any2\265\004\n\nMoni",
"toring\022a\n\024GetCanonicalRpcStats\022\026.google." +
"protobuf.Empty\032/.grpc.instrumentation.v1" +
"alpha.CanonicalRpcStats\"\000\022e\n\010GetStats\022*." +
"grpc.instrumentation.v1alpha.StatsReques" +
"t\032+.grpc.instrumentation.v1alpha.StatsRe" +
"sponse\"\000\022i\n\nWatchStats\022*.grpc.instrument" +
"ation.v1alpha.StatsRequest\032+.grpc.instru" +
"mentation.v1alpha.StatsResponse\"\0000\001\022m\n\020G" +
"etRequestTraces\022*.grpc.instrumentation.v" +
"1alpha.TraceRequest\032+.grpc.instrumentati",
"on.v1alpha.TraceResponse\"\000\022\202\001\n\027GetCustom" +
"MonitoringData\0221.grpc.instrumentation.v1" +
"alpha.MonitoringDataGroup\0322.grpc.instrum" +
"entation.v1alpha.CustomMonitoringData\"\000B" +
"4\n\037io.grpc.instrumentation.v1alphaB\017Moni" +
"toringProtoP\001b\006proto3"
};
com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner assigner =
new com.google.protobuf.Descriptors.FileDescriptor. InternalDescriptorAssigner() {
@ -153,24 +146,18 @@ public final class MonitoringProto {
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_grpc_instrumentation_v1alpha_CanonicalRpcStats_descriptor,
new java.lang.String[] { "RpcClientErrors", "RpcClientCompletedRpcs", "RpcClientStartedRpcs", "RpcClientElapsedTime", "RpcClientServerElapsedTime", "RpcClientRequestBytes", "RpcClientResponseBytes", "RpcClientRequestCount", "RpcClientResponseCount", "RpcServerErrors", "RpcServerCompletedRpcs", "RpcServerServerElapsedTime", "RpcServerRequestBytes", "RpcServerResponseBytes", "RpcServerRequestCount", "RpcServerResponseCount", "RpcServerElapsedTime", });
internal_static_grpc_instrumentation_v1alpha_CanonicalRpcStats_View_descriptor =
internal_static_grpc_instrumentation_v1alpha_CanonicalRpcStats_descriptor.getNestedTypes().get(0);
internal_static_grpc_instrumentation_v1alpha_CanonicalRpcStats_View_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_grpc_instrumentation_v1alpha_CanonicalRpcStats_View_descriptor,
new java.lang.String[] { "MeasurementDescriptor", "ViewDescriptor", "View", });
internal_static_grpc_instrumentation_v1alpha_StatsRequest_descriptor =
getDescriptor().getMessageTypes().get(1);
internal_static_grpc_instrumentation_v1alpha_StatsRequest_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_grpc_instrumentation_v1alpha_StatsRequest_descriptor,
new java.lang.String[] { });
new java.lang.String[] { "ViewNames", "MeasurementNames", "DontIncludeDescriptorsInFirstResponse", });
internal_static_grpc_instrumentation_v1alpha_StatsResponse_descriptor =
getDescriptor().getMessageTypes().get(2);
internal_static_grpc_instrumentation_v1alpha_StatsResponse_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_grpc_instrumentation_v1alpha_StatsResponse_descriptor,
new java.lang.String[] { });
new java.lang.String[] { "MeasurementDescriptor", "ViewDescriptor", "View", });
internal_static_grpc_instrumentation_v1alpha_TraceRequest_descriptor =
getDescriptor().getMessageTypes().get(3);
internal_static_grpc_instrumentation_v1alpha_TraceRequest_fieldAccessorTable = new

695
services/src/generated/main/java/io/grpc/instrumentation/v1alpha/StatsRequest.java
View File

@ -5,7 +5,8 @@ package io.grpc.instrumentation.v1alpha;
/**
* <pre>
* TODO(aveitch): Complete definition of this type
* This message is sent when requesting a set of stats (Census Views) from
* a client system, as part of the MonitoringService API's.
* </pre>
*
* Protobuf type {@code grpc.instrumentation.v1alpha.StatsRequest}
@ -19,6 +20,9 @@ public final class StatsRequest extends
super(builder);
}
private StatsRequest() {
viewNames_ = com.google.protobuf.LazyStringArrayList.EMPTY;
measurementNames_ = com.google.protobuf.LazyStringArrayList.EMPTY;
dontIncludeDescriptorsInFirstResponse_ = false;
}
@java.lang.Override
@ -31,6 +35,7 @@ public final class StatsRequest extends
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
this();
int mutable_bitField0_ = 0;
try {
boolean done = false;
while (!done) {
@ -45,6 +50,29 @@ public final class StatsRequest extends
}
break;
}
case 10: {
java.lang.String s = input.readStringRequireUtf8();
if (!((mutable_bitField0_ & 0x00000001) == 0x00000001)) {
viewNames_ = new com.google.protobuf.LazyStringArrayList();
mutable_bitField0_ |= 0x00000001;
}
viewNames_.add(s);
break;
}
case 18: {
java.lang.String s = input.readStringRequireUtf8();
if (!((mutable_bitField0_ & 0x00000002) == 0x00000002)) {
measurementNames_ = new com.google.protobuf.LazyStringArrayList();
mutable_bitField0_ |= 0x00000002;
}
measurementNames_.add(s);
break;
}
case 24: {
dontIncludeDescriptorsInFirstResponse_ = input.readBool();
break;
}
}
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
@ -53,6 +81,12 @@ public final class StatsRequest extends
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
} finally {
if (((mutable_bitField0_ & 0x00000001) == 0x00000001)) {
viewNames_ = viewNames_.getUnmodifiableView();
}
if (((mutable_bitField0_ & 0x00000002) == 0x00000002)) {
measurementNames_ = measurementNames_.getUnmodifiableView();
}
makeExtensionsImmutable();
}
}
@ -68,6 +102,160 @@ public final class StatsRequest extends
io.grpc.instrumentation.v1alpha.StatsRequest.class, io.grpc.instrumentation.v1alpha.StatsRequest.Builder.class);
}
private int bitField0_;
public static final int VIEW_NAMES_FIELD_NUMBER = 1;
private com.google.protobuf.LazyStringList viewNames_;
/**
* <pre>
* An optional set of ViewDescriptor names. Only Views using these
* descriptors will be sent back in the response. If no names are provided,
* then all Views present in the client system will be included in every
* response. If measurement_names is also provided, then Views matching the
* intersection of the two are returned.
* TODO(aveitch): Consider making this a list of regexes or prefix matches in
* the future.
* </pre>
*
* <code>repeated string view_names = 1;</code>
*/
public com.google.protobuf.ProtocolStringList
getViewNamesList() {
return viewNames_;
}
/**
* <pre>
* An optional set of ViewDescriptor names. Only Views using these
* descriptors will be sent back in the response. If no names are provided,
* then all Views present in the client system will be included in every
* response. If measurement_names is also provided, then Views matching the
* intersection of the two are returned.
* TODO(aveitch): Consider making this a list of regexes or prefix matches in
* the future.
* </pre>
*
* <code>repeated string view_names = 1;</code>
*/
public int getViewNamesCount() {
return viewNames_.size();
}
/**
* <pre>
* An optional set of ViewDescriptor names. Only Views using these
* descriptors will be sent back in the response. If no names are provided,
* then all Views present in the client system will be included in every
* response. If measurement_names is also provided, then Views matching the
* intersection of the two are returned.
* TODO(aveitch): Consider making this a list of regexes or prefix matches in
* the future.
* </pre>
*
* <code>repeated string view_names = 1;</code>
*/
public java.lang.String getViewNames(int index) {
return viewNames_.get(index);
}
/**
* <pre>
* An optional set of ViewDescriptor names. Only Views using these
* descriptors will be sent back in the response. If no names are provided,
* then all Views present in the client system will be included in every
* response. If measurement_names is also provided, then Views matching the
* intersection of the two are returned.
* TODO(aveitch): Consider making this a list of regexes or prefix matches in
* the future.
* </pre>
*
* <code>repeated string view_names = 1;</code>
*/
public com.google.protobuf.ByteString
getViewNamesBytes(int index) {
return viewNames_.getByteString(index);
}
public static final int MEASUREMENT_NAMES_FIELD_NUMBER = 2;
private com.google.protobuf.LazyStringList measurementNames_;
/**
* <pre>
* An optional set of MeasurementDescriptor names. Only Views using these
* descriptors will be sent back in the response. If no names are provided,
* then all Views present in the client system will be included in every
* response. If view_names is also provided, then Views matching the
* intersection of the two are returned.
* TODO(aveitch): Consider making this a list of regexes or prefix matches in
* the future.
* </pre>
*
* <code>repeated string measurement_names = 2;</code>
*/
public com.google.protobuf.ProtocolStringList
getMeasurementNamesList() {
return measurementNames_;
}
/**
* <pre>
* An optional set of MeasurementDescriptor names. Only Views using these
* descriptors will be sent back in the response. If no names are provided,
* then all Views present in the client system will be included in every
* response. If view_names is also provided, then Views matching the
* intersection of the two are returned.
* TODO(aveitch): Consider making this a list of regexes or prefix matches in
* the future.
* </pre>
*
* <code>repeated string measurement_names = 2;</code>
*/
public int getMeasurementNamesCount() {
return measurementNames_.size();
}
/**
* <pre>
* An optional set of MeasurementDescriptor names. Only Views using these
* descriptors will be sent back in the response. If no names are provided,
* then all Views present in the client system will be included in every
* response. If view_names is also provided, then Views matching the
* intersection of the two are returned.
* TODO(aveitch): Consider making this a list of regexes or prefix matches in
* the future.
* </pre>
*
* <code>repeated string measurement_names = 2;</code>
*/
public java.lang.String getMeasurementNames(int index) {
return measurementNames_.get(index);
}
/**
* <pre>
* An optional set of MeasurementDescriptor names. Only Views using these
* descriptors will be sent back in the response. If no names are provided,
* then all Views present in the client system will be included in every
* response. If view_names is also provided, then Views matching the
* intersection of the two are returned.
* TODO(aveitch): Consider making this a list of regexes or prefix matches in
* the future.
* </pre>
*
* <code>repeated string measurement_names = 2;</code>
*/
public com.google.protobuf.ByteString
getMeasurementNamesBytes(int index) {
return measurementNames_.getByteString(index);
}
public static final int DONT_INCLUDE_DESCRIPTORS_IN_FIRST_RESPONSE_FIELD_NUMBER = 3;
private boolean dontIncludeDescriptorsInFirstResponse_;
/**
* <pre>
* By default, the MeasurementDescriptors and ViewDescriptors corresponding to
* the Views that are returned in a StatsResponse will be included in the
* first such response. Set this to true to have them not sent.
* </pre>
*
* <code>bool dont_include_descriptors_in_first_response = 3;</code>
*/
public boolean getDontIncludeDescriptorsInFirstResponse() {
return dontIncludeDescriptorsInFirstResponse_;
}
private byte memoizedIsInitialized = -1;
public final boolean isInitialized() {
byte isInitialized = memoizedIsInitialized;
@ -80,6 +268,15 @@ public final class StatsRequest extends
public void writeTo(com.google.protobuf.CodedOutputStream output)
throws java.io.IOException {
for (int i = 0; i < viewNames_.size(); i++) {
com.google.protobuf.GeneratedMessageV3.writeString(output, 1, viewNames_.getRaw(i));
}
for (int i = 0; i < measurementNames_.size(); i++) {
com.google.protobuf.GeneratedMessageV3.writeString(output, 2, measurementNames_.getRaw(i));
}
if (dontIncludeDescriptorsInFirstResponse_ != false) {
output.writeBool(3, dontIncludeDescriptorsInFirstResponse_);
}
}
public int getSerializedSize() {
@ -87,6 +284,26 @@ public final class StatsRequest extends
if (size != -1) return size;
size = 0;
{
int dataSize = 0;
for (int i = 0; i < viewNames_.size(); i++) {
dataSize += computeStringSizeNoTag(viewNames_.getRaw(i));
}
size += dataSize;
size += 1 * getViewNamesList().size();
}
{
int dataSize = 0;
for (int i = 0; i < measurementNames_.size(); i++) {
dataSize += computeStringSizeNoTag(measurementNames_.getRaw(i));
}
size += dataSize;
size += 1 * getMeasurementNamesList().size();
}
if (dontIncludeDescriptorsInFirstResponse_ != false) {
size += com.google.protobuf.CodedOutputStream
.computeBoolSize(3, dontIncludeDescriptorsInFirstResponse_);
}
memoizedSize = size;
return size;
}
@ -103,6 +320,12 @@ public final class StatsRequest extends
io.grpc.instrumentation.v1alpha.StatsRequest other = (io.grpc.instrumentation.v1alpha.StatsRequest) obj;
boolean result = true;
result = result && getViewNamesList()
.equals(other.getViewNamesList());
result = result && getMeasurementNamesList()
.equals(other.getMeasurementNamesList());
result = result && (getDontIncludeDescriptorsInFirstResponse()
== other.getDontIncludeDescriptorsInFirstResponse());
return result;
}
@ -113,6 +336,17 @@ public final class StatsRequest extends
}
int hash = 41;
hash = (19 * hash) + getDescriptor().hashCode();
if (getViewNamesCount() > 0) {
hash = (37 * hash) + VIEW_NAMES_FIELD_NUMBER;
hash = (53 * hash) + getViewNamesList().hashCode();
}
if (getMeasurementNamesCount() > 0) {
hash = (37 * hash) + MEASUREMENT_NAMES_FIELD_NUMBER;
hash = (53 * hash) + getMeasurementNamesList().hashCode();
}
hash = (37 * hash) + DONT_INCLUDE_DESCRIPTORS_IN_FIRST_RESPONSE_FIELD_NUMBER;
hash = (53 * hash) + com.google.protobuf.Internal.hashBoolean(
getDontIncludeDescriptorsInFirstResponse());
hash = (29 * hash) + unknownFields.hashCode();
memoizedHashCode = hash;
return hash;
@ -197,7 +431,8 @@ public final class StatsRequest extends
}
/**
* <pre>
* TODO(aveitch): Complete definition of this type
* This message is sent when requesting a set of stats (Census Views) from
* a client system, as part of the MonitoringService API's.
* </pre>
*
* Protobuf type {@code grpc.instrumentation.v1alpha.StatsRequest}
@ -235,6 +470,12 @@ public final class StatsRequest extends
}
public Builder clear() {
super.clear();
viewNames_ = com.google.protobuf.LazyStringArrayList.EMPTY;
bitField0_ = (bitField0_ & ~0x00000001);
measurementNames_ = com.google.protobuf.LazyStringArrayList.EMPTY;
bitField0_ = (bitField0_ & ~0x00000002);
dontIncludeDescriptorsInFirstResponse_ = false;
return this;
}
@ -257,6 +498,20 @@ public final class StatsRequest extends
public io.grpc.instrumentation.v1alpha.StatsRequest buildPartial() {
io.grpc.instrumentation.v1alpha.StatsRequest result = new io.grpc.instrumentation.v1alpha.StatsRequest(this);
int from_bitField0_ = bitField0_;
int to_bitField0_ = 0;
if (((bitField0_ & 0x00000001) == 0x00000001)) {
viewNames_ = viewNames_.getUnmodifiableView();
bitField0_ = (bitField0_ & ~0x00000001);
}
result.viewNames_ = viewNames_;
if (((bitField0_ & 0x00000002) == 0x00000002)) {
measurementNames_ = measurementNames_.getUnmodifiableView();
bitField0_ = (bitField0_ & ~0x00000002);
}
result.measurementNames_ = measurementNames_;
result.dontIncludeDescriptorsInFirstResponse_ = dontIncludeDescriptorsInFirstResponse_;
result.bitField0_ = to_bitField0_;
onBuilt();
return result;
}
@ -298,6 +553,29 @@ public final class StatsRequest extends
public Builder mergeFrom(io.grpc.instrumentation.v1alpha.StatsRequest other) {
if (other == io.grpc.instrumentation.v1alpha.StatsRequest.getDefaultInstance()) return this;
if (!other.viewNames_.isEmpty()) {
if (viewNames_.isEmpty()) {
viewNames_ = other.viewNames_;
bitField0_ = (bitField0_ & ~0x00000001);
} else {
ensureViewNamesIsMutable();
viewNames_.addAll(other.viewNames_);
}
onChanged();
}
if (!other.measurementNames_.isEmpty()) {
if (measurementNames_.isEmpty()) {
measurementNames_ = other.measurementNames_;
bitField0_ = (bitField0_ & ~0x00000002);
} else {
ensureMeasurementNamesIsMutable();
measurementNames_.addAll(other.measurementNames_);
}
onChanged();
}
if (other.getDontIncludeDescriptorsInFirstResponse() != false) {
setDontIncludeDescriptorsInFirstResponse(other.getDontIncludeDescriptorsInFirstResponse());
}
onChanged();
return this;
}
@ -323,6 +601,419 @@ public final class StatsRequest extends
}
return this;
}
private int bitField0_;
private com.google.protobuf.LazyStringList viewNames_ = com.google.protobuf.LazyStringArrayList.EMPTY;
private void ensureViewNamesIsMutable() {
if (!((bitField0_ & 0x00000001) == 0x00000001)) {
viewNames_ = new com.google.protobuf.LazyStringArrayList(viewNames_);
bitField0_ |= 0x00000001;
}
}
/**
* <pre>
* An optional set of ViewDescriptor names. Only Views using these
* descriptors will be sent back in the response. If no names are provided,
* then all Views present in the client system will be included in every
* response. If measurement_names is also provided, then Views matching the
* intersection of the two are returned.
* TODO(aveitch): Consider making this a list of regexes or prefix matches in
* the future.
* </pre>
*
* <code>repeated string view_names = 1;</code>
*/
public com.google.protobuf.ProtocolStringList
getViewNamesList() {
return viewNames_.getUnmodifiableView();
}
/**
* <pre>
* An optional set of ViewDescriptor names. Only Views using these
* descriptors will be sent back in the response. If no names are provided,
* then all Views present in the client system will be included in every
* response. If measurement_names is also provided, then Views matching the
* intersection of the two are returned.
* TODO(aveitch): Consider making this a list of regexes or prefix matches in
* the future.
* </pre>
*
* <code>repeated string view_names = 1;</code>
*/
public int getViewNamesCount() {
return viewNames_.size();
}
/**
* <pre>
* An optional set of ViewDescriptor names. Only Views using these
* descriptors will be sent back in the response. If no names are provided,
* then all Views present in the client system will be included in every
* response. If measurement_names is also provided, then Views matching the
* intersection of the two are returned.
* TODO(aveitch): Consider making this a list of regexes or prefix matches in
* the future.
* </pre>
*
* <code>repeated string view_names = 1;</code>
*/
public java.lang.String getViewNames(int index) {
return viewNames_.get(index);
}
/**
* <pre>
* An optional set of ViewDescriptor names. Only Views using these
* descriptors will be sent back in the response. If no names are provided,
* then all Views present in the client system will be included in every
* response. If measurement_names is also provided, then Views matching the
* intersection of the two are returned.
* TODO(aveitch): Consider making this a list of regexes or prefix matches in
* the future.
* </pre>
*
* <code>repeated string view_names = 1;</code>
*/
public com.google.protobuf.ByteString
getViewNamesBytes(int index) {
return viewNames_.getByteString(index);
}
/**
* <pre>
* An optional set of ViewDescriptor names. Only Views using these
* descriptors will be sent back in the response. If no names are provided,
* then all Views present in the client system will be included in every
* response. If measurement_names is also provided, then Views matching the
* intersection of the two are returned.
* TODO(aveitch): Consider making this a list of regexes or prefix matches in
* the future.
* </pre>
*
* <code>repeated string view_names = 1;</code>
*/
public Builder setViewNames(
int index, java.lang.String value) {
if (value == null) {
throw new NullPointerException();
}
ensureViewNamesIsMutable();
viewNames_.set(index, value);
onChanged();
return this;
}
/**
* <pre>
* An optional set of ViewDescriptor names. Only Views using these
* descriptors will be sent back in the response. If no names are provided,
* then all Views present in the client system will be included in every
* response. If measurement_names is also provided, then Views matching the
* intersection of the two are returned.
* TODO(aveitch): Consider making this a list of regexes or prefix matches in
* the future.
* </pre>
*
* <code>repeated string view_names = 1;</code>
*/
public Builder addViewNames(
java.lang.String value) {
if (value == null) {
throw new NullPointerException();
}
ensureViewNamesIsMutable();
viewNames_.add(value);
onChanged();
return this;
}
/**
* <pre>
* An optional set of ViewDescriptor names. Only Views using these
* descriptors will be sent back in the response. If no names are provided,
* then all Views present in the client system will be included in every
* response. If measurement_names is also provided, then Views matching the
* intersection of the two are returned.
* TODO(aveitch): Consider making this a list of regexes or prefix matches in
* the future.
* </pre>
*
* <code>repeated string view_names = 1;</code>
*/
public Builder addAllViewNames(
java.lang.Iterable<java.lang.String> values) {
ensureViewNamesIsMutable();
com.google.protobuf.AbstractMessageLite.Builder.addAll(
values, viewNames_);
onChanged();
return this;
}
/**
* <pre>
* An optional set of ViewDescriptor names. Only Views using these
* descriptors will be sent back in the response. If no names are provided,
* then all Views present in the client system will be included in every
* response. If measurement_names is also provided, then Views matching the
* intersection of the two are returned.
* TODO(aveitch): Consider making this a list of regexes or prefix matches in
* the future.
* </pre>
*
* <code>repeated string view_names = 1;</code>
*/
public Builder clearViewNames() {
viewNames_ = com.google.protobuf.LazyStringArrayList.EMPTY;
bitField0_ = (bitField0_ & ~0x00000001);
onChanged();
return this;
}
/**
* <pre>
* An optional set of ViewDescriptor names. Only Views using these
* descriptors will be sent back in the response. If no names are provided,
* then all Views present in the client system will be included in every
* response. If measurement_names is also provided, then Views matching the
* intersection of the two are returned.
* TODO(aveitch): Consider making this a list of regexes or prefix matches in
* the future.
* </pre>
*
* <code>repeated string view_names = 1;</code>
*/
public Builder addViewNamesBytes(
com.google.protobuf.ByteString value) {
if (value == null) {
throw new NullPointerException();
}
checkByteStringIsUtf8(value);
ensureViewNamesIsMutable();
viewNames_.add(value);
onChanged();
return this;
}
private com.google.protobuf.LazyStringList measurementNames_ = com.google.protobuf.LazyStringArrayList.EMPTY;
private void ensureMeasurementNamesIsMutable() {
if (!((bitField0_ & 0x00000002) == 0x00000002)) {
measurementNames_ = new com.google.protobuf.LazyStringArrayList(measurementNames_);
bitField0_ |= 0x00000002;
}
}
/**
* <pre>
* An optional set of MeasurementDescriptor names. Only Views using these
* descriptors will be sent back in the response. If no names are provided,
* then all Views present in the client system will be included in every
* response. If view_names is also provided, then Views matching the
* intersection of the two are returned.
* TODO(aveitch): Consider making this a list of regexes or prefix matches in
* the future.
* </pre>
*
* <code>repeated string measurement_names = 2;</code>
*/
public com.google.protobuf.ProtocolStringList
getMeasurementNamesList() {
return measurementNames_.getUnmodifiableView();
}
/**
* <pre>
* An optional set of MeasurementDescriptor names. Only Views using these
* descriptors will be sent back in the response. If no names are provided,
* then all Views present in the client system will be included in every
* response. If view_names is also provided, then Views matching the
* intersection of the two are returned.
* TODO(aveitch): Consider making this a list of regexes or prefix matches in
* the future.
* </pre>
*
* <code>repeated string measurement_names = 2;</code>
*/
public int getMeasurementNamesCount() {
return measurementNames_.size();
}
/**
* <pre>
* An optional set of MeasurementDescriptor names. Only Views using these
* descriptors will be sent back in the response. If no names are provided,
* then all Views present in the client system will be included in every
* response. If view_names is also provided, then Views matching the
* intersection of the two are returned.
* TODO(aveitch): Consider making this a list of regexes or prefix matches in
* the future.
* </pre>
*
* <code>repeated string measurement_names = 2;</code>
*/
public java.lang.String getMeasurementNames(int index) {
return measurementNames_.get(index);
}
/**
* <pre>
* An optional set of MeasurementDescriptor names. Only Views using these
* descriptors will be sent back in the response. If no names are provided,
* then all Views present in the client system will be included in every
* response. If view_names is also provided, then Views matching the
* intersection of the two are returned.
* TODO(aveitch): Consider making this a list of regexes or prefix matches in
* the future.
* </pre>
*
* <code>repeated string measurement_names = 2;</code>
*/
public com.google.protobuf.ByteString
getMeasurementNamesBytes(int index) {
return measurementNames_.getByteString(index);
}
/**
* <pre>
* An optional set of MeasurementDescriptor names. Only Views using these
* descriptors will be sent back in the response. If no names are provided,
* then all Views present in the client system will be included in every
* response. If view_names is also provided, then Views matching the
* intersection of the two are returned.
* TODO(aveitch): Consider making this a list of regexes or prefix matches in
* the future.
* </pre>
*
* <code>repeated string measurement_names = 2;</code>
*/
public Builder setMeasurementNames(
int index, java.lang.String value) {
if (value == null) {
throw new NullPointerException();
}
ensureMeasurementNamesIsMutable();
measurementNames_.set(index, value);
onChanged();
return this;
}
/**
* <pre>
* An optional set of MeasurementDescriptor names. Only Views using these
* descriptors will be sent back in the response. If no names are provided,
* then all Views present in the client system will be included in every
* response. If view_names is also provided, then Views matching the
* intersection of the two are returned.
* TODO(aveitch): Consider making this a list of regexes or prefix matches in
* the future.
* </pre>
*
* <code>repeated string measurement_names = 2;</code>
*/
public Builder addMeasurementNames(
java.lang.String value) {
if (value == null) {
throw new NullPointerException();
}
ensureMeasurementNamesIsMutable();
measurementNames_.add(value);
onChanged();
return this;
}
/**
* <pre>
* An optional set of MeasurementDescriptor names. Only Views using these
* descriptors will be sent back in the response. If no names are provided,
* then all Views present in the client system will be included in every
* response. If view_names is also provided, then Views matching the
* intersection of the two are returned.
* TODO(aveitch): Consider making this a list of regexes or prefix matches in
* the future.
* </pre>
*
* <code>repeated string measurement_names = 2;</code>
*/
public Builder addAllMeasurementNames(
java.lang.Iterable<java.lang.String> values) {
ensureMeasurementNamesIsMutable();
com.google.protobuf.AbstractMessageLite.Builder.addAll(
values, measurementNames_);
onChanged();
return this;
}
/**
* <pre>
* An optional set of MeasurementDescriptor names. Only Views using these
* descriptors will be sent back in the response. If no names are provided,
* then all Views present in the client system will be included in every
* response. If view_names is also provided, then Views matching the
* intersection of the two are returned.
* TODO(aveitch): Consider making this a list of regexes or prefix matches in
* the future.
* </pre>
*
* <code>repeated string measurement_names = 2;</code>
*/
public Builder clearMeasurementNames() {
measurementNames_ = com.google.protobuf.LazyStringArrayList.EMPTY;
bitField0_ = (bitField0_ & ~0x00000002);
onChanged();
return this;
}
/**
* <pre>
* An optional set of MeasurementDescriptor names. Only Views using these
* descriptors will be sent back in the response. If no names are provided,
* then all Views present in the client system will be included in every
* response. If view_names is also provided, then Views matching the
* intersection of the two are returned.
* TODO(aveitch): Consider making this a list of regexes or prefix matches in
* the future.
* </pre>
*
* <code>repeated string measurement_names = 2;</code>
*/
public Builder addMeasurementNamesBytes(
com.google.protobuf.ByteString value) {
if (value == null) {
throw new NullPointerException();
}
checkByteStringIsUtf8(value);
ensureMeasurementNamesIsMutable();
measurementNames_.add(value);
onChanged();
return this;
}
private boolean dontIncludeDescriptorsInFirstResponse_ ;
/**
* <pre>
* By default, the MeasurementDescriptors and ViewDescriptors corresponding to
* the Views that are returned in a StatsResponse will be included in the
* first such response. Set this to true to have them not sent.
* </pre>
*
* <code>bool dont_include_descriptors_in_first_response = 3;</code>
*/
public boolean getDontIncludeDescriptorsInFirstResponse() {
return dontIncludeDescriptorsInFirstResponse_;
}
/**
* <pre>
* By default, the MeasurementDescriptors and ViewDescriptors corresponding to
* the Views that are returned in a StatsResponse will be included in the
* first such response. Set this to true to have them not sent.
* </pre>
*
* <code>bool dont_include_descriptors_in_first_response = 3;</code>
*/
public Builder setDontIncludeDescriptorsInFirstResponse(boolean value) {
dontIncludeDescriptorsInFirstResponse_ = value;
onChanged();
return this;
}
/**
* <pre>
* By default, the MeasurementDescriptors and ViewDescriptors corresponding to
* the Views that are returned in a StatsResponse will be included in the
* first such response. Set this to true to have them not sent.
* </pre>
*
* <code>bool dont_include_descriptors_in_first_response = 3;</code>
*/
public Builder clearDontIncludeDescriptorsInFirstResponse() {
dontIncludeDescriptorsInFirstResponse_ = false;
onChanged();
return this;
}
public final Builder setUnknownFields(
final com.google.protobuf.UnknownFieldSet unknownFields) {
return this;

129
services/src/generated/main/java/io/grpc/instrumentation/v1alpha/StatsRequestOrBuilder.java
View File

@ -6,4 +6,133 @@ package io.grpc.instrumentation.v1alpha;
public interface StatsRequestOrBuilder extends
// @@protoc_insertion_point(interface_extends:grpc.instrumentation.v1alpha.StatsRequest)
com.google.protobuf.MessageOrBuilder {
/**
* <pre>
* An optional set of ViewDescriptor names. Only Views using these
* descriptors will be sent back in the response. If no names are provided,
* then all Views present in the client system will be included in every
* response. If measurement_names is also provided, then Views matching the
* intersection of the two are returned.
* TODO(aveitch): Consider making this a list of regexes or prefix matches in
* the future.
* </pre>
*
* <code>repeated string view_names = 1;</code>
*/
java.util.List<java.lang.String>
getViewNamesList();
/**
* <pre>
* An optional set of ViewDescriptor names. Only Views using these
* descriptors will be sent back in the response. If no names are provided,
* then all Views present in the client system will be included in every
* response. If measurement_names is also provided, then Views matching the
* intersection of the two are returned.
* TODO(aveitch): Consider making this a list of regexes or prefix matches in
* the future.
* </pre>
*
* <code>repeated string view_names = 1;</code>
*/
int getViewNamesCount();
/**
* <pre>
* An optional set of ViewDescriptor names. Only Views using these
* descriptors will be sent back in the response. If no names are provided,
* then all Views present in the client system will be included in every
* response. If measurement_names is also provided, then Views matching the
* intersection of the two are returned.
* TODO(aveitch): Consider making this a list of regexes or prefix matches in
* the future.
* </pre>
*
* <code>repeated string view_names = 1;</code>
*/
java.lang.String getViewNames(int index);
/**
* <pre>
* An optional set of ViewDescriptor names. Only Views using these
* descriptors will be sent back in the response. If no names are provided,
* then all Views present in the client system will be included in every
* response. If measurement_names is also provided, then Views matching the
* intersection of the two are returned.
* TODO(aveitch): Consider making this a list of regexes or prefix matches in
* the future.
* </pre>
*
* <code>repeated string view_names = 1;</code>
*/
com.google.protobuf.ByteString
getViewNamesBytes(int index);
/**
* <pre>
* An optional set of MeasurementDescriptor names. Only Views using these
* descriptors will be sent back in the response. If no names are provided,
* then all Views present in the client system will be included in every
* response. If view_names is also provided, then Views matching the
* intersection of the two are returned.
* TODO(aveitch): Consider making this a list of regexes or prefix matches in
* the future.
* </pre>
*
* <code>repeated string measurement_names = 2;</code>
*/
java.util.List<java.lang.String>
getMeasurementNamesList();
/**
* <pre>
* An optional set of MeasurementDescriptor names. Only Views using these
* descriptors will be sent back in the response. If no names are provided,
* then all Views present in the client system will be included in every
* response. If view_names is also provided, then Views matching the
* intersection of the two are returned.
* TODO(aveitch): Consider making this a list of regexes or prefix matches in
* the future.
* </pre>
*
* <code>repeated string measurement_names = 2;</code>
*/
int getMeasurementNamesCount();
/**
* <pre>
* An optional set of MeasurementDescriptor names. Only Views using these
* descriptors will be sent back in the response. If no names are provided,
* then all Views present in the client system will be included in every
* response. If view_names is also provided, then Views matching the
* intersection of the two are returned.
* TODO(aveitch): Consider making this a list of regexes or prefix matches in
* the future.
* </pre>
*
* <code>repeated string measurement_names = 2;</code>
*/
java.lang.String getMeasurementNames(int index);
/**
* <pre>
* An optional set of MeasurementDescriptor names. Only Views using these
* descriptors will be sent back in the response. If no names are provided,
* then all Views present in the client system will be included in every
* response. If view_names is also provided, then Views matching the
* intersection of the two are returned.
* TODO(aveitch): Consider making this a list of regexes or prefix matches in
* the future.
* </pre>
*
* <code>repeated string measurement_names = 2;</code>
*/
com.google.protobuf.ByteString
getMeasurementNamesBytes(int index);
/**
* <pre>
* By default, the MeasurementDescriptors and ViewDescriptors corresponding to
* the Views that are returned in a StatsResponse will be included in the
* first such response. Set this to true to have them not sent.
* </pre>
*
* <code>bool dont_include_descriptors_in_first_response = 3;</code>
*/
boolean getDontIncludeDescriptorsInFirstResponse();
}

706
services/src/generated/main/java/io/grpc/instrumentation/v1alpha/StatsResponse.java
View File

@ -5,7 +5,8 @@ package io.grpc.instrumentation.v1alpha;
/**
* <pre>
* TODO(aveitch): Complete definition of this type
* This message contains all information relevant to a single View. It is the
* return type for GetStats and WatchStats, and used in CanonicalRpcStats.
* </pre>
*
* Protobuf type {@code grpc.instrumentation.v1alpha.StatsResponse}
@ -31,6 +32,7 @@ public final class StatsResponse extends
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
this();
int mutable_bitField0_ = 0;
try {
boolean done = false;
while (!done) {
@ -45,6 +47,45 @@ public final class StatsResponse extends
}
break;
}
case 10: {
com.google.instrumentation.stats.proto.CensusProto.MeasurementDescriptor.Builder subBuilder = null;
if (measurementDescriptor_ != null) {
subBuilder = measurementDescriptor_.toBuilder();
}
measurementDescriptor_ = input.readMessage(com.google.instrumentation.stats.proto.CensusProto.MeasurementDescriptor.parser(), extensionRegistry);
if (subBuilder != null) {
subBuilder.mergeFrom(measurementDescriptor_);
measurementDescriptor_ = subBuilder.buildPartial();
}
break;
}
case 18: {
com.google.instrumentation.stats.proto.CensusProto.ViewDescriptor.Builder subBuilder = null;
if (viewDescriptor_ != null) {
subBuilder = viewDescriptor_.toBuilder();
}
viewDescriptor_ = input.readMessage(com.google.instrumentation.stats.proto.CensusProto.ViewDescriptor.parser(), extensionRegistry);
if (subBuilder != null) {
subBuilder.mergeFrom(viewDescriptor_);
viewDescriptor_ = subBuilder.buildPartial();
}
break;
}
case 26: {
com.google.instrumentation.stats.proto.CensusProto.View.Builder subBuilder = null;
if (view_ != null) {
subBuilder = view_.toBuilder();
}
view_ = input.readMessage(com.google.instrumentation.stats.proto.CensusProto.View.parser(), extensionRegistry);
if (subBuilder != null) {
subBuilder.mergeFrom(view_);
view_ = subBuilder.buildPartial();
}
break;
}
}
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
@ -68,6 +109,108 @@ public final class StatsResponse extends
io.grpc.instrumentation.v1alpha.StatsResponse.class, io.grpc.instrumentation.v1alpha.StatsResponse.Builder.class);
}
public static final int MEASUREMENT_DESCRIPTOR_FIELD_NUMBER = 1;
private com.google.instrumentation.stats.proto.CensusProto.MeasurementDescriptor measurementDescriptor_;
/**
* <pre>
* A StatsResponse can optionally contain the MeasurementDescriptor and
* ViewDescriptor for the View. These will be sent in the first WatchStats
* response, or all GetStats and GetCanonicalRpcStats responses. These will
* not be set for {Get,Watch}Stats if
* dont_include_descriptors_in_first_response is set to true in the
* StatsRequest.
* </pre>
*
* <code>.google.instrumentation.MeasurementDescriptor measurement_descriptor = 1;</code>
*/
public boolean hasMeasurementDescriptor() {
return measurementDescriptor_ != null;
}
/**
* <pre>
* A StatsResponse can optionally contain the MeasurementDescriptor and
* ViewDescriptor for the View. These will be sent in the first WatchStats
* response, or all GetStats and GetCanonicalRpcStats responses. These will
* not be set for {Get,Watch}Stats if
* dont_include_descriptors_in_first_response is set to true in the
* StatsRequest.
* </pre>
*
* <code>.google.instrumentation.MeasurementDescriptor measurement_descriptor = 1;</code>
*/
public com.google.instrumentation.stats.proto.CensusProto.MeasurementDescriptor getMeasurementDescriptor() {
return measurementDescriptor_ == null ? com.google.instrumentation.stats.proto.CensusProto.MeasurementDescriptor.getDefaultInstance() : measurementDescriptor_;
}
/**
* <pre>
* A StatsResponse can optionally contain the MeasurementDescriptor and
* ViewDescriptor for the View. These will be sent in the first WatchStats
* response, or all GetStats and GetCanonicalRpcStats responses. These will
* not be set for {Get,Watch}Stats if
* dont_include_descriptors_in_first_response is set to true in the
* StatsRequest.
* </pre>
*
* <code>.google.instrumentation.MeasurementDescriptor measurement_descriptor = 1;</code>
*/
public com.google.instrumentation.stats.proto.CensusProto.MeasurementDescriptorOrBuilder getMeasurementDescriptorOrBuilder() {
return getMeasurementDescriptor();
}
public static final int VIEW_DESCRIPTOR_FIELD_NUMBER = 2;
private com.google.instrumentation.stats.proto.CensusProto.ViewDescriptor viewDescriptor_;
/**
* <code>.google.instrumentation.ViewDescriptor view_descriptor = 2;</code>
*/
public boolean hasViewDescriptor() {
return viewDescriptor_ != null;
}
/**
* <code>.google.instrumentation.ViewDescriptor view_descriptor = 2;</code>
*/
public com.google.instrumentation.stats.proto.CensusProto.ViewDescriptor getViewDescriptor() {
return viewDescriptor_ == null ? com.google.instrumentation.stats.proto.CensusProto.ViewDescriptor.getDefaultInstance() : viewDescriptor_;
}
/**
* <code>.google.instrumentation.ViewDescriptor view_descriptor = 2;</code>
*/
public com.google.instrumentation.stats.proto.CensusProto.ViewDescriptorOrBuilder getViewDescriptorOrBuilder() {
return getViewDescriptor();
}
public static final int VIEW_FIELD_NUMBER = 3;
private com.google.instrumentation.stats.proto.CensusProto.View view_;
/**
* <pre>
* The View data.
* </pre>
*
* <code>.google.instrumentation.View view = 3;</code>
*/
public boolean hasView() {
return view_ != null;
}
/**
* <pre>
* The View data.
* </pre>
*
* <code>.google.instrumentation.View view = 3;</code>
*/
public com.google.instrumentation.stats.proto.CensusProto.View getView() {
return view_ == null ? com.google.instrumentation.stats.proto.CensusProto.View.getDefaultInstance() : view_;
}
/**
* <pre>
* The View data.
* </pre>
*
* <code>.google.instrumentation.View view = 3;</code>
*/
public com.google.instrumentation.stats.proto.CensusProto.ViewOrBuilder getViewOrBuilder() {
return getView();
}
private byte memoizedIsInitialized = -1;
public final boolean isInitialized() {
byte isInitialized = memoizedIsInitialized;
@ -80,6 +223,15 @@ public final class StatsResponse extends
public void writeTo(com.google.protobuf.CodedOutputStream output)
throws java.io.IOException {
if (measurementDescriptor_ != null) {
output.writeMessage(1, getMeasurementDescriptor());
}
if (viewDescriptor_ != null) {
output.writeMessage(2, getViewDescriptor());
}
if (view_ != null) {
output.writeMessage(3, getView());
}
}
public int getSerializedSize() {
@ -87,6 +239,18 @@ public final class StatsResponse extends
if (size != -1) return size;
size = 0;
if (measurementDescriptor_ != null) {
size += com.google.protobuf.CodedOutputStream
.computeMessageSize(1, getMeasurementDescriptor());
}
if (viewDescriptor_ != null) {
size += com.google.protobuf.CodedOutputStream
.computeMessageSize(2, getViewDescriptor());
}
if (view_ != null) {
size += com.google.protobuf.CodedOutputStream
.computeMessageSize(3, getView());
}
memoizedSize = size;
return size;
}
@ -103,6 +267,21 @@ public final class StatsResponse extends
io.grpc.instrumentation.v1alpha.StatsResponse other = (io.grpc.instrumentation.v1alpha.StatsResponse) obj;
boolean result = true;
result = result && (hasMeasurementDescriptor() == other.hasMeasurementDescriptor());
if (hasMeasurementDescriptor()) {
result = result && getMeasurementDescriptor()
.equals(other.getMeasurementDescriptor());
}
result = result && (hasViewDescriptor() == other.hasViewDescriptor());
if (hasViewDescriptor()) {
result = result && getViewDescriptor()
.equals(other.getViewDescriptor());
}
result = result && (hasView() == other.hasView());
if (hasView()) {
result = result && getView()
.equals(other.getView());
}
return result;
}
@ -113,6 +292,18 @@ public final class StatsResponse extends
}
int hash = 41;
hash = (19 * hash) + getDescriptor().hashCode();
if (hasMeasurementDescriptor()) {
hash = (37 * hash) + MEASUREMENT_DESCRIPTOR_FIELD_NUMBER;
hash = (53 * hash) + getMeasurementDescriptor().hashCode();
}
if (hasViewDescriptor()) {
hash = (37 * hash) + VIEW_DESCRIPTOR_FIELD_NUMBER;
hash = (53 * hash) + getViewDescriptor().hashCode();
}
if (hasView()) {
hash = (37 * hash) + VIEW_FIELD_NUMBER;
hash = (53 * hash) + getView().hashCode();
}
hash = (29 * hash) + unknownFields.hashCode();
memoizedHashCode = hash;
return hash;
@ -197,7 +388,8 @@ public final class StatsResponse extends
}
/**
* <pre>
* TODO(aveitch): Complete definition of this type
* This message contains all information relevant to a single View. It is the
* return type for GetStats and WatchStats, and used in CanonicalRpcStats.
* </pre>
*
* Protobuf type {@code grpc.instrumentation.v1alpha.StatsResponse}
@ -235,6 +427,24 @@ public final class StatsResponse extends
}
public Builder clear() {
super.clear();
if (measurementDescriptorBuilder_ == null) {
measurementDescriptor_ = null;
} else {
measurementDescriptor_ = null;
measurementDescriptorBuilder_ = null;
}
if (viewDescriptorBuilder_ == null) {
viewDescriptor_ = null;
} else {
viewDescriptor_ = null;
viewDescriptorBuilder_ = null;
}
if (viewBuilder_ == null) {
view_ = null;
} else {
view_ = null;
viewBuilder_ = null;
}
return this;
}
@ -257,6 +467,21 @@ public final class StatsResponse extends
public io.grpc.instrumentation.v1alpha.StatsResponse buildPartial() {
io.grpc.instrumentation.v1alpha.StatsResponse result = new io.grpc.instrumentation.v1alpha.StatsResponse(this);
if (measurementDescriptorBuilder_ == null) {
result.measurementDescriptor_ = measurementDescriptor_;
} else {
result.measurementDescriptor_ = measurementDescriptorBuilder_.build();
}
if (viewDescriptorBuilder_ == null) {
result.viewDescriptor_ = viewDescriptor_;
} else {
result.viewDescriptor_ = viewDescriptorBuilder_.build();
}
if (viewBuilder_ == null) {
result.view_ = view_;
} else {
result.view_ = viewBuilder_.build();
}
onBuilt();
return result;
}
@ -298,6 +523,15 @@ public final class StatsResponse extends
public Builder mergeFrom(io.grpc.instrumentation.v1alpha.StatsResponse other) {
if (other == io.grpc.instrumentation.v1alpha.StatsResponse.getDefaultInstance()) return this;
if (other.hasMeasurementDescriptor()) {
mergeMeasurementDescriptor(other.getMeasurementDescriptor());
}
if (other.hasViewDescriptor()) {
mergeViewDescriptor(other.getViewDescriptor());
}
if (other.hasView()) {
mergeView(other.getView());
}
onChanged();
return this;
}
@ -323,6 +557,474 @@ public final class StatsResponse extends
}
return this;
}
private com.google.instrumentation.stats.proto.CensusProto.MeasurementDescriptor measurementDescriptor_ = null;
private com.google.protobuf.SingleFieldBuilderV3<
com.google.instrumentation.stats.proto.CensusProto.MeasurementDescriptor, com.google.instrumentation.stats.proto.CensusProto.MeasurementDescriptor.Builder, com.google.instrumentation.stats.proto.CensusProto.MeasurementDescriptorOrBuilder> measurementDescriptorBuilder_;
/**
* <pre>
* A StatsResponse can optionally contain the MeasurementDescriptor and
* ViewDescriptor for the View. These will be sent in the first WatchStats
* response, or all GetStats and GetCanonicalRpcStats responses. These will
* not be set for {Get,Watch}Stats if
* dont_include_descriptors_in_first_response is set to true in the
* StatsRequest.
* </pre>
*
* <code>.google.instrumentation.MeasurementDescriptor measurement_descriptor = 1;</code>
*/
public boolean hasMeasurementDescriptor() {
return measurementDescriptorBuilder_ != null || measurementDescriptor_ != null;
}
/**
* <pre>
* A StatsResponse can optionally contain the MeasurementDescriptor and
* ViewDescriptor for the View. These will be sent in the first WatchStats
* response, or all GetStats and GetCanonicalRpcStats responses. These will
* not be set for {Get,Watch}Stats if
* dont_include_descriptors_in_first_response is set to true in the
* StatsRequest.
* </pre>
*
* <code>.google.instrumentation.MeasurementDescriptor measurement_descriptor = 1;</code>
*/
public com.google.instrumentation.stats.proto.CensusProto.MeasurementDescriptor getMeasurementDescriptor() {
if (measurementDescriptorBuilder_ == null) {
return measurementDescriptor_ == null ? com.google.instrumentation.stats.proto.CensusProto.MeasurementDescriptor.getDefaultInstance() : measurementDescriptor_;
} else {
return measurementDescriptorBuilder_.getMessage();
}
}
/**
* <pre>
* A StatsResponse can optionally contain the MeasurementDescriptor and
* ViewDescriptor for the View. These will be sent in the first WatchStats
* response, or all GetStats and GetCanonicalRpcStats responses. These will
* not be set for {Get,Watch}Stats if
* dont_include_descriptors_in_first_response is set to true in the
* StatsRequest.
* </pre>
*
* <code>.google.instrumentation.MeasurementDescriptor measurement_descriptor = 1;</code>
*/
public Builder setMeasurementDescriptor(com.google.instrumentation.stats.proto.CensusProto.MeasurementDescriptor value) {
if (measurementDescriptorBuilder_ == null) {
if (value == null) {
throw new NullPointerException();
}
measurementDescriptor_ = value;
onChanged();
} else {
measurementDescriptorBuilder_.setMessage(value);
}
return this;
}
/**
* <pre>
* A StatsResponse can optionally contain the MeasurementDescriptor and
* ViewDescriptor for the View. These will be sent in the first WatchStats
* response, or all GetStats and GetCanonicalRpcStats responses. These will
* not be set for {Get,Watch}Stats if
* dont_include_descriptors_in_first_response is set to true in the
* StatsRequest.
* </pre>
*
* <code>.google.instrumentation.MeasurementDescriptor measurement_descriptor = 1;</code>
*/
public Builder setMeasurementDescriptor(
com.google.instrumentation.stats.proto.CensusProto.MeasurementDescriptor.Builder builderForValue) {
if (measurementDescriptorBuilder_ == null) {
measurementDescriptor_ = builderForValue.build();
onChanged();
} else {
measurementDescriptorBuilder_.setMessage(builderForValue.build());
}
return this;
}
/**
* <pre>
* A StatsResponse can optionally contain the MeasurementDescriptor and
* ViewDescriptor for the View. These will be sent in the first WatchStats
* response, or all GetStats and GetCanonicalRpcStats responses. These will
* not be set for {Get,Watch}Stats if
* dont_include_descriptors_in_first_response is set to true in the
* StatsRequest.
* </pre>
*
* <code>.google.instrumentation.MeasurementDescriptor measurement_descriptor = 1;</code>
*/
public Builder mergeMeasurementDescriptor(com.google.instrumentation.stats.proto.CensusProto.MeasurementDescriptor value) {
if (measurementDescriptorBuilder_ == null) {
if (measurementDescriptor_ != null) {
measurementDescriptor_ =
com.google.instrumentation.stats.proto.CensusProto.MeasurementDescriptor.newBuilder(measurementDescriptor_).mergeFrom(value).buildPartial();
} else {
measurementDescriptor_ = value;
}
onChanged();
} else {
measurementDescriptorBuilder_.mergeFrom(value);
}
return this;
}
/**
* <pre>
* A StatsResponse can optionally contain the MeasurementDescriptor and
* ViewDescriptor for the View. These will be sent in the first WatchStats
* response, or all GetStats and GetCanonicalRpcStats responses. These will
* not be set for {Get,Watch}Stats if
* dont_include_descriptors_in_first_response is set to true in the
* StatsRequest.
* </pre>
*
* <code>.google.instrumentation.MeasurementDescriptor measurement_descriptor = 1;</code>
*/
public Builder clearMeasurementDescriptor() {
if (measurementDescriptorBuilder_ == null) {
measurementDescriptor_ = null;
onChanged();
} else {
measurementDescriptor_ = null;
measurementDescriptorBuilder_ = null;
}
return this;
}
/**
* <pre>
* A StatsResponse can optionally contain the MeasurementDescriptor and
* ViewDescriptor for the View. These will be sent in the first WatchStats
* response, or all GetStats and GetCanonicalRpcStats responses. These will
* not be set for {Get,Watch}Stats if
* dont_include_descriptors_in_first_response is set to true in the
* StatsRequest.
* </pre>
*
* <code>.google.instrumentation.MeasurementDescriptor measurement_descriptor = 1;</code>
*/
public com.google.instrumentation.stats.proto.CensusProto.MeasurementDescriptor.Builder getMeasurementDescriptorBuilder() {
onChanged();
return getMeasurementDescriptorFieldBuilder().getBuilder();
}
/**
* <pre>
* A StatsResponse can optionally contain the MeasurementDescriptor and
* ViewDescriptor for the View. These will be sent in the first WatchStats
* response, or all GetStats and GetCanonicalRpcStats responses. These will
* not be set for {Get,Watch}Stats if
* dont_include_descriptors_in_first_response is set to true in the
* StatsRequest.
* </pre>
*
* <code>.google.instrumentation.MeasurementDescriptor measurement_descriptor = 1;</code>
*/
public com.google.instrumentation.stats.proto.CensusProto.MeasurementDescriptorOrBuilder getMeasurementDescriptorOrBuilder() {
if (measurementDescriptorBuilder_ != null) {
return measurementDescriptorBuilder_.getMessageOrBuilder();
} else {
return measurementDescriptor_ == null ?
com.google.instrumentation.stats.proto.CensusProto.MeasurementDescriptor.getDefaultInstance() : measurementDescriptor_;
}
}
/**
* <pre>
* A StatsResponse can optionally contain the MeasurementDescriptor and
* ViewDescriptor for the View. These will be sent in the first WatchStats
* response, or all GetStats and GetCanonicalRpcStats responses. These will
* not be set for {Get,Watch}Stats if
* dont_include_descriptors_in_first_response is set to true in the
* StatsRequest.
* </pre>
*
* <code>.google.instrumentation.MeasurementDescriptor measurement_descriptor = 1;</code>
*/
private com.google.protobuf.SingleFieldBuilderV3<
com.google.instrumentation.stats.proto.CensusProto.MeasurementDescriptor, com.google.instrumentation.stats.proto.CensusProto.MeasurementDescriptor.Builder, com.google.instrumentation.stats.proto.CensusProto.MeasurementDescriptorOrBuilder>
getMeasurementDescriptorFieldBuilder() {
if (measurementDescriptorBuilder_ == null) {
measurementDescriptorBuilder_ = new com.google.protobuf.SingleFieldBuilderV3<
com.google.instrumentation.stats.proto.CensusProto.MeasurementDescriptor, com.google.instrumentation.stats.proto.CensusProto.MeasurementDescriptor.Builder, com.google.instrumentation.stats.proto.CensusProto.MeasurementDescriptorOrBuilder>(
getMeasurementDescriptor(),
getParentForChildren(),
isClean());
measurementDescriptor_ = null;
}
return measurementDescriptorBuilder_;
}
private com.google.instrumentation.stats.proto.CensusProto.ViewDescriptor viewDescriptor_ = null;
private com.google.protobuf.SingleFieldBuilderV3<
com.google.instrumentation.stats.proto.CensusProto.ViewDescriptor, com.google.instrumentation.stats.proto.CensusProto.ViewDescriptor.Builder, com.google.instrumentation.stats.proto.CensusProto.ViewDescriptorOrBuilder> viewDescriptorBuilder_;
/**
* <code>.google.instrumentation.ViewDescriptor view_descriptor = 2;</code>
*/
public boolean hasViewDescriptor() {
return viewDescriptorBuilder_ != null || viewDescriptor_ != null;
}
/**
* <code>.google.instrumentation.ViewDescriptor view_descriptor = 2;</code>
*/
public com.google.instrumentation.stats.proto.CensusProto.ViewDescriptor getViewDescriptor() {
if (viewDescriptorBuilder_ == null) {
return viewDescriptor_ == null ? com.google.instrumentation.stats.proto.CensusProto.ViewDescriptor.getDefaultInstance() : viewDescriptor_;
} else {
return viewDescriptorBuilder_.getMessage();
}
}
/**
* <code>.google.instrumentation.ViewDescriptor view_descriptor = 2;</code>
*/
public Builder setViewDescriptor(com.google.instrumentation.stats.proto.CensusProto.ViewDescriptor value) {
if (viewDescriptorBuilder_ == null) {
if (value == null) {
throw new NullPointerException();
}
viewDescriptor_ = value;
onChanged();
} else {
viewDescriptorBuilder_.setMessage(value);
}
return this;
}
/**
* <code>.google.instrumentation.ViewDescriptor view_descriptor = 2;</code>
*/
public Builder setViewDescriptor(
com.google.instrumentation.stats.proto.CensusProto.ViewDescriptor.Builder builderForValue) {
if (viewDescriptorBuilder_ == null) {
viewDescriptor_ = builderForValue.build();
onChanged();
} else {
viewDescriptorBuilder_.setMessage(builderForValue.build());
}
return this;
}
/**
* <code>.google.instrumentation.ViewDescriptor view_descriptor = 2;</code>
*/
public Builder mergeViewDescriptor(com.google.instrumentation.stats.proto.CensusProto.ViewDescriptor value) {
if (viewDescriptorBuilder_ == null) {
if (viewDescriptor_ != null) {
viewDescriptor_ =
com.google.instrumentation.stats.proto.CensusProto.ViewDescriptor.newBuilder(viewDescriptor_).mergeFrom(value).buildPartial();
} else {
viewDescriptor_ = value;
}
onChanged();
} else {
viewDescriptorBuilder_.mergeFrom(value);
}
return this;
}
/**
* <code>.google.instrumentation.ViewDescriptor view_descriptor = 2;</code>
*/
public Builder clearViewDescriptor() {
if (viewDescriptorBuilder_ == null) {
viewDescriptor_ = null;
onChanged();
} else {
viewDescriptor_ = null;
viewDescriptorBuilder_ = null;
}
return this;
}
/**
* <code>.google.instrumentation.ViewDescriptor view_descriptor = 2;</code>
*/
public com.google.instrumentation.stats.proto.CensusProto.ViewDescriptor.Builder getViewDescriptorBuilder() {
onChanged();
return getViewDescriptorFieldBuilder().getBuilder();
}
/**
* <code>.google.instrumentation.ViewDescriptor view_descriptor = 2;</code>
*/
public com.google.instrumentation.stats.proto.CensusProto.ViewDescriptorOrBuilder getViewDescriptorOrBuilder() {
if (viewDescriptorBuilder_ != null) {
return viewDescriptorBuilder_.getMessageOrBuilder();
} else {
return viewDescriptor_ == null ?
com.google.instrumentation.stats.proto.CensusProto.ViewDescriptor.getDefaultInstance() : viewDescriptor_;
}
}
/**
* <code>.google.instrumentation.ViewDescriptor view_descriptor = 2;</code>
*/
private com.google.protobuf.SingleFieldBuilderV3<
com.google.instrumentation.stats.proto.CensusProto.ViewDescriptor, com.google.instrumentation.stats.proto.CensusProto.ViewDescriptor.Builder, com.google.instrumentation.stats.proto.CensusProto.ViewDescriptorOrBuilder>
getViewDescriptorFieldBuilder() {
if (viewDescriptorBuilder_ == null) {
viewDescriptorBuilder_ = new com.google.protobuf.SingleFieldBuilderV3<
com.google.instrumentation.stats.proto.CensusProto.ViewDescriptor, com.google.instrumentation.stats.proto.CensusProto.ViewDescriptor.Builder, com.google.instrumentation.stats.proto.CensusProto.ViewDescriptorOrBuilder>(
getViewDescriptor(),
getParentForChildren(),
isClean());
viewDescriptor_ = null;
}
return viewDescriptorBuilder_;
}
private com.google.instrumentation.stats.proto.CensusProto.View view_ = null;
private com.google.protobuf.SingleFieldBuilderV3<
com.google.instrumentation.stats.proto.CensusProto.View, com.google.instrumentation.stats.proto.CensusProto.View.Builder, com.google.instrumentation.stats.proto.CensusProto.ViewOrBuilder> viewBuilder_;
/**
* <pre>
* The View data.
* </pre>
*
* <code>.google.instrumentation.View view = 3;</code>
*/
public boolean hasView() {
return viewBuilder_ != null || view_ != null;
}
/**
* <pre>
* The View data.
* </pre>
*
* <code>.google.instrumentation.View view = 3;</code>
*/
public com.google.instrumentation.stats.proto.CensusProto.View getView() {
if (viewBuilder_ == null) {
return view_ == null ? com.google.instrumentation.stats.proto.CensusProto.View.getDefaultInstance() : view_;
} else {
return viewBuilder_.getMessage();
}
}
/**
* <pre>
* The View data.
* </pre>
*
* <code>.google.instrumentation.View view = 3;</code>
*/
public Builder setView(com.google.instrumentation.stats.proto.CensusProto.View value) {
if (viewBuilder_ == null) {
if (value == null) {
throw new NullPointerException();
}
view_ = value;
onChanged();
} else {
viewBuilder_.setMessage(value);
}
return this;
}
/**
* <pre>
* The View data.
* </pre>
*
* <code>.google.instrumentation.View view = 3;</code>
*/
public Builder setView(
com.google.instrumentation.stats.proto.CensusProto.View.Builder builderForValue) {
if (viewBuilder_ == null) {
view_ = builderForValue.build();
onChanged();
} else {
viewBuilder_.setMessage(builderForValue.build());
}
return this;
}
/**
* <pre>
* The View data.
* </pre>
*
* <code>.google.instrumentation.View view = 3;</code>
*/
public Builder mergeView(com.google.instrumentation.stats.proto.CensusProto.View value) {
if (viewBuilder_ == null) {
if (view_ != null) {
view_ =
com.google.instrumentation.stats.proto.CensusProto.View.newBuilder(view_).mergeFrom(value).buildPartial();
} else {
view_ = value;
}
onChanged();
} else {
viewBuilder_.mergeFrom(value);
}
return this;
}
/**
* <pre>
* The View data.
* </pre>
*
* <code>.google.instrumentation.View view = 3;</code>
*/
public Builder clearView() {
if (viewBuilder_ == null) {
view_ = null;
onChanged();
} else {
view_ = null;
viewBuilder_ = null;
}
return this;
}
/**
* <pre>
* The View data.
* </pre>
*
* <code>.google.instrumentation.View view = 3;</code>
*/
public com.google.instrumentation.stats.proto.CensusProto.View.Builder getViewBuilder() {
onChanged();
return getViewFieldBuilder().getBuilder();
}
/**
* <pre>
* The View data.
* </pre>
*
* <code>.google.instrumentation.View view = 3;</code>
*/
public com.google.instrumentation.stats.proto.CensusProto.ViewOrBuilder getViewOrBuilder() {
if (viewBuilder_ != null) {
return viewBuilder_.getMessageOrBuilder();
} else {
return view_ == null ?
com.google.instrumentation.stats.proto.CensusProto.View.getDefaultInstance() : view_;
}
}
/**
* <pre>
* The View data.
* </pre>
*
* <code>.google.instrumentation.View view = 3;</code>
*/
private com.google.protobuf.SingleFieldBuilderV3<
com.google.instrumentation.stats.proto.CensusProto.View, com.google.instrumentation.stats.proto.CensusProto.View.Builder, com.google.instrumentation.stats.proto.CensusProto.ViewOrBuilder>
getViewFieldBuilder() {
if (viewBuilder_ == null) {
viewBuilder_ = new com.google.protobuf.SingleFieldBuilderV3<
com.google.instrumentation.stats.proto.CensusProto.View, com.google.instrumentation.stats.proto.CensusProto.View.Builder, com.google.instrumentation.stats.proto.CensusProto.ViewOrBuilder>(
getView(),
getParentForChildren(),
isClean());
view_ = null;
}
return viewBuilder_;
}
public final Builder setUnknownFields(
final com.google.protobuf.UnknownFieldSet unknownFields) {
return this;

78
services/src/generated/main/java/io/grpc/instrumentation/v1alpha/StatsResponseOrBuilder.java
View File

@ -6,4 +6,82 @@ package io.grpc.instrumentation.v1alpha;
public interface StatsResponseOrBuilder extends
// @@protoc_insertion_point(interface_extends:grpc.instrumentation.v1alpha.StatsResponse)
com.google.protobuf.MessageOrBuilder {
/**
* <pre>
* A StatsResponse can optionally contain the MeasurementDescriptor and
* ViewDescriptor for the View. These will be sent in the first WatchStats
* response, or all GetStats and GetCanonicalRpcStats responses. These will
* not be set for {Get,Watch}Stats if
* dont_include_descriptors_in_first_response is set to true in the
* StatsRequest.
* </pre>
*
* <code>.google.instrumentation.MeasurementDescriptor measurement_descriptor = 1;</code>
*/
boolean hasMeasurementDescriptor();
/**
* <pre>
* A StatsResponse can optionally contain the MeasurementDescriptor and
* ViewDescriptor for the View. These will be sent in the first WatchStats
* response, or all GetStats and GetCanonicalRpcStats responses. These will
* not be set for {Get,Watch}Stats if
* dont_include_descriptors_in_first_response is set to true in the
* StatsRequest.
* </pre>
*
* <code>.google.instrumentation.MeasurementDescriptor measurement_descriptor = 1;</code>
*/
com.google.instrumentation.stats.proto.CensusProto.MeasurementDescriptor getMeasurementDescriptor();
/**
* <pre>
* A StatsResponse can optionally contain the MeasurementDescriptor and
* ViewDescriptor for the View. These will be sent in the first WatchStats
* response, or all GetStats and GetCanonicalRpcStats responses. These will
* not be set for {Get,Watch}Stats if
* dont_include_descriptors_in_first_response is set to true in the
* StatsRequest.
* </pre>
*
* <code>.google.instrumentation.MeasurementDescriptor measurement_descriptor = 1;</code>
*/
com.google.instrumentation.stats.proto.CensusProto.MeasurementDescriptorOrBuilder getMeasurementDescriptorOrBuilder();
/**
* <code>.google.instrumentation.ViewDescriptor view_descriptor = 2;</code>
*/
boolean hasViewDescriptor();
/**
* <code>.google.instrumentation.ViewDescriptor view_descriptor = 2;</code>
*/
com.google.instrumentation.stats.proto.CensusProto.ViewDescriptor getViewDescriptor();
/**
* <code>.google.instrumentation.ViewDescriptor view_descriptor = 2;</code>
*/
com.google.instrumentation.stats.proto.CensusProto.ViewDescriptorOrBuilder getViewDescriptorOrBuilder();
/**
* <pre>
* The View data.
* </pre>
*
* <code>.google.instrumentation.View view = 3;</code>
*/
boolean hasView();
/**
* <pre>
* The View data.
* </pre>
*
* <code>.google.instrumentation.View view = 3;</code>
*/
com.google.instrumentation.stats.proto.CensusProto.View getView();
/**
* <pre>
* The View data.
* </pre>
*
* <code>.google.instrumentation.View view = 3;</code>
*/
com.google.instrumentation.stats.proto.CensusProto.ViewOrBuilder getViewOrBuilder();
}

8
services/src/main/java/io/grpc/services/MonitoringUtil.java
View File

@ -52,7 +52,7 @@ import com.google.instrumentation.stats.ViewDescriptor.DistributionViewDescripto
import com.google.instrumentation.stats.ViewDescriptor.IntervalViewDescriptor;
import com.google.instrumentation.stats.proto.CensusProto;
import io.grpc.ExperimentalApi;
import io.grpc.instrumentation.v1alpha.CanonicalRpcStats;
import io.grpc.instrumentation.v1alpha.StatsResponse;
/** Utility methods to support {@link MonitoringService}. */
@ExperimentalApi("https://github.com/grpc/grpc-java/issues/2776")
@ -60,9 +60,9 @@ final class MonitoringUtil {
private MonitoringUtil() {}
/** Serialize a {@link View} and associated descriptors to a {@link CanonicalRpcStats.View}. */
static CanonicalRpcStats.View buildCanonicalRpcStatsView(View view) {
return CanonicalRpcStats.View.newBuilder()
/** Serialize a {@link View} and associated descriptors to a {@link StatsResponse}. */
static StatsResponse buildCanonicalRpcStatsView(View view) {
return StatsResponse.newBuilder()
.setMeasurementDescriptor(
serializeMeasurementDescriptor(view.getViewDescriptor().getMeasurementDescriptor()))
.setViewDescriptor(serializeViewDescriptor(view.getViewDescriptor()))

83
services/src/main/proto/grpc/instrumentation/v1alpha/monitoring.proto
View File

@ -50,8 +50,6 @@ service Monitoring {
// Query the server for specific stats
rpc GetStats(StatsRequest) returns (StatsResponse) {
// TODO(aveitch, ericgribkoff): Pease define the stats response message
// StatsRequest would specifically identify the stats to be returned.
}
// Request the server to stream back snapshots of the requested stats
@ -76,39 +74,67 @@ service Monitoring {
// Canonical RPC stats exported by gRPC.
message CanonicalRpcStats {
// Wrapper combining View and ViewDescriptor.
message View {
google.instrumentation.MeasurementDescriptor measurement_descriptor = 1;
google.instrumentation.ViewDescriptor view_descriptor = 2;
google.instrumentation.View view = 3;
}
View rpc_client_errors = 1;
View rpc_client_completed_rpcs = 2;
View rpc_client_started_rpcs = 3;
View rpc_client_elapsed_time = 4;
View rpc_client_server_elapsed_time = 5;
View rpc_client_request_bytes = 6;
View rpc_client_response_bytes = 7;
View rpc_client_request_count = 8;
View rpc_client_response_count = 9;
View rpc_server_errors = 10;
View rpc_server_completed_rpcs = 11;
View rpc_server_server_elapsed_time = 12;
View rpc_server_request_bytes = 13;
View rpc_server_response_bytes = 14;
View rpc_server_request_count = 15;
View rpc_server_response_count = 16;
View rpc_server_elapsed_time = 17;
StatsResponse rpc_client_errors = 1;
StatsResponse rpc_client_completed_rpcs = 2;
StatsResponse rpc_client_started_rpcs = 3;
StatsResponse rpc_client_elapsed_time = 4;
StatsResponse rpc_client_server_elapsed_time = 5;
StatsResponse rpc_client_request_bytes = 6;
StatsResponse rpc_client_response_bytes = 7;
StatsResponse rpc_client_request_count = 8;
StatsResponse rpc_client_response_count = 9;
StatsResponse rpc_server_errors = 10;
StatsResponse rpc_server_completed_rpcs = 11;
StatsResponse rpc_server_server_elapsed_time = 12;
StatsResponse rpc_server_request_bytes = 13;
StatsResponse rpc_server_response_bytes = 14;
StatsResponse rpc_server_request_count = 15;
StatsResponse rpc_server_response_count = 16;
StatsResponse rpc_server_elapsed_time = 17;
//TODO(ericgribkoff) Add minute-hour interval stats.
}
// This message is sent when requesting a set of stats (Census Views) from
// a client system, as part of the MonitoringService API's.
message StatsRequest {
// TODO(aveitch): Complete definition of this type
// An optional set of ViewDescriptor names. Only Views using these
// descriptors will be sent back in the response. If no names are provided,
// then all Views present in the client system will be included in every
// response. If measurement_names is also provided, then Views matching the
// intersection of the two are returned.
// TODO(aveitch): Consider making this a list of regexes or prefix matches in
// the future.
repeated string view_names = 1;
// An optional set of MeasurementDescriptor names. Only Views using these
// descriptors will be sent back in the response. If no names are provided,
// then all Views present in the client system will be included in every
// response. If view_names is also provided, then Views matching the
// intersection of the two are returned.
// TODO(aveitch): Consider making this a list of regexes or prefix matches in
// the future.
repeated string measurement_names = 2;
// By default, the MeasurementDescriptors and ViewDescriptors corresponding to
// the Views that are returned in a StatsResponse will be included in the
// first such response. Set this to true to have them not sent.
bool dont_include_descriptors_in_first_response = 3;
}
// This message contains all information relevant to a single View. It is the
// return type for GetStats and WatchStats, and used in CanonicalRpcStats.
message StatsResponse {
// TODO(aveitch): Complete definition of this type
// A StatsResponse can optionally contain the MeasurementDescriptor and
// ViewDescriptor for the View. These will be sent in the first WatchStats
// response, or all GetStats and GetCanonicalRpcStats responses. These will
// not be set for {Get,Watch}Stats if
// dont_include_descriptors_in_first_response is set to true in the
// StatsRequest.
google.instrumentation.MeasurementDescriptor measurement_descriptor = 1;
google.instrumentation.ViewDescriptor view_descriptor = 2;
// The View data.
google.instrumentation.View view = 3;
}
message TraceRequest {
@ -128,4 +154,3 @@ message CustomMonitoringData {
// can be any application specific monitoring data
google.protobuf.Any contents = 1;
}

14
services/src/test/java/io/grpc/services/MonitoringUtilTest.java
View File

@ -52,7 +52,7 @@ import com.google.instrumentation.stats.View.IntervalView;
import com.google.instrumentation.stats.ViewDescriptor.DistributionViewDescriptor;
import com.google.instrumentation.stats.ViewDescriptor.IntervalViewDescriptor;
import com.google.instrumentation.stats.proto.CensusProto;
import io.grpc.instrumentation.v1alpha.CanonicalRpcStats;
import io.grpc.instrumentation.v1alpha.StatsResponse;
import java.util.Arrays;
import org.junit.Test;
import org.junit.runner.RunWith;
@ -64,14 +64,14 @@ public class MonitoringUtilTest {
@Test
public void buildCanonicalRpcStatsViewForDistributionView() throws Exception {
assertEquals(
DISTRIBUTION_CANONICAL_STATS_PROTO,
DISTRIBUTION_STATS_RESPONSE_PROTO,
MonitoringUtil.buildCanonicalRpcStatsView(DISTRIBUTION_VIEW));
}
@Test
public void buildCanonicalRpcStatsViewForIntervalView() throws Exception {
assertEquals(
INTERVAL_CANONICAL_STATS_PROTO, MonitoringUtil.buildCanonicalRpcStatsView(INTERVAL_VIEW));
INTERVAL_STATS_RESPONSE_PROTO, MonitoringUtil.buildCanonicalRpcStatsView(INTERVAL_VIEW));
}
@Test
@ -286,8 +286,8 @@ public class MonitoringUtilTest {
.setViewName(DISTRIBUTION_VIEW_NAME)
.setDistributionView(DISTRIBUTION_VIEW_PROTO)
.build();
private static final CanonicalRpcStats.View DISTRIBUTION_CANONICAL_STATS_PROTO =
CanonicalRpcStats.View.newBuilder()
private static final StatsResponse DISTRIBUTION_STATS_RESPONSE_PROTO =
StatsResponse.newBuilder()
.setMeasurementDescriptor(MEASUREMENT_DESC_PROTO)
.setViewDescriptor(DISTRIBUTION_VIEW_DESC_PROTO)
.setView(VIEW_WITH_DISTRIBUTION_VIEW_PROTO)
@ -356,8 +356,8 @@ public class MonitoringUtilTest {
.setViewName(INTERVAL_VIEW_NAME)
.setIntervalView(INTERVAL_VIEW_PROTO)
.build();
private static final CanonicalRpcStats.View INTERVAL_CANONICAL_STATS_PROTO =
CanonicalRpcStats.View.newBuilder()
private static final StatsResponse INTERVAL_STATS_RESPONSE_PROTO =
StatsResponse.newBuilder()
.setMeasurementDescriptor(MEASUREMENT_DESC_PROTO)
.setViewDescriptor(INTERVAL_VIEW_DESC_PROTO)
.setView(VIEW_WITH_INTERVAL_VIEW_PROTO)