mirror of https://github.com/grpc/grpc-java.git
compiler, stub: Add @RpcMethod annotation
This annotation will enable Java APT to generate code. Addresses part of #3173.
This commit is contained in:
parent
dd57b667cc
commit
9229e30287
|
|
@ -30,6 +30,12 @@ public final class HandshakerServiceGrpc {
|
|||
private static volatile io.grpc.MethodDescriptor<io.grpc.alts.internal.Handshaker.HandshakerReq,
|
||||
io.grpc.alts.internal.Handshaker.HandshakerResp> getDoHandshakeMethod;
|
||||
|
||||
@io.grpc.stub.annotations.RpcMethod(
|
||||
fullServiceName = "grpc.gcp.HandshakerService",
|
||||
methodName = "DoHandshake",
|
||||
inputType = io.grpc.alts.internal.Handshaker.HandshakerReq.class,
|
||||
outputType = io.grpc.alts.internal.Handshaker.HandshakerResp.class,
|
||||
methodType = io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
|
||||
public static io.grpc.MethodDescriptor<io.grpc.alts.internal.Handshaker.HandshakerReq,
|
||||
io.grpc.alts.internal.Handshaker.HandshakerResp> getDoHandshakeMethod() {
|
||||
io.grpc.MethodDescriptor<io.grpc.alts.internal.Handshaker.HandshakerReq, io.grpc.alts.internal.Handshaker.HandshakerResp> getDoHandshakeMethod;
|
||||
|
|
|
|||
|
|
@ -30,6 +30,12 @@ public final class BenchmarkServiceGrpc {
|
|||
private static volatile io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Messages.SimpleRequest,
|
||||
io.grpc.benchmarks.proto.Messages.SimpleResponse> getUnaryCallMethod;
|
||||
|
||||
@io.grpc.stub.annotations.RpcMethod(
|
||||
fullServiceName = "grpc.testing.BenchmarkService",
|
||||
methodName = "UnaryCall",
|
||||
inputType = io.grpc.benchmarks.proto.Messages.SimpleRequest.class,
|
||||
outputType = io.grpc.benchmarks.proto.Messages.SimpleResponse.class,
|
||||
methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
|
||||
public static io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Messages.SimpleRequest,
|
||||
io.grpc.benchmarks.proto.Messages.SimpleResponse> getUnaryCallMethod() {
|
||||
io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Messages.SimpleRequest, io.grpc.benchmarks.proto.Messages.SimpleResponse> getUnaryCallMethod;
|
||||
|
|
@ -57,6 +63,12 @@ public final class BenchmarkServiceGrpc {
|
|||
private static volatile io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Messages.SimpleRequest,
|
||||
io.grpc.benchmarks.proto.Messages.SimpleResponse> getStreamingCallMethod;
|
||||
|
||||
@io.grpc.stub.annotations.RpcMethod(
|
||||
fullServiceName = "grpc.testing.BenchmarkService",
|
||||
methodName = "StreamingCall",
|
||||
inputType = io.grpc.benchmarks.proto.Messages.SimpleRequest.class,
|
||||
outputType = io.grpc.benchmarks.proto.Messages.SimpleResponse.class,
|
||||
methodType = io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
|
||||
public static io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Messages.SimpleRequest,
|
||||
io.grpc.benchmarks.proto.Messages.SimpleResponse> getStreamingCallMethod() {
|
||||
io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Messages.SimpleRequest, io.grpc.benchmarks.proto.Messages.SimpleResponse> getStreamingCallMethod;
|
||||
|
|
@ -84,6 +96,12 @@ public final class BenchmarkServiceGrpc {
|
|||
private static volatile io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Messages.SimpleRequest,
|
||||
io.grpc.benchmarks.proto.Messages.SimpleResponse> getStreamingFromClientMethod;
|
||||
|
||||
@io.grpc.stub.annotations.RpcMethod(
|
||||
fullServiceName = "grpc.testing.BenchmarkService",
|
||||
methodName = "StreamingFromClient",
|
||||
inputType = io.grpc.benchmarks.proto.Messages.SimpleRequest.class,
|
||||
outputType = io.grpc.benchmarks.proto.Messages.SimpleResponse.class,
|
||||
methodType = io.grpc.MethodDescriptor.MethodType.CLIENT_STREAMING)
|
||||
public static io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Messages.SimpleRequest,
|
||||
io.grpc.benchmarks.proto.Messages.SimpleResponse> getStreamingFromClientMethod() {
|
||||
io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Messages.SimpleRequest, io.grpc.benchmarks.proto.Messages.SimpleResponse> getStreamingFromClientMethod;
|
||||
|
|
@ -111,6 +129,12 @@ public final class BenchmarkServiceGrpc {
|
|||
private static volatile io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Messages.SimpleRequest,
|
||||
io.grpc.benchmarks.proto.Messages.SimpleResponse> getStreamingFromServerMethod;
|
||||
|
||||
@io.grpc.stub.annotations.RpcMethod(
|
||||
fullServiceName = "grpc.testing.BenchmarkService",
|
||||
methodName = "StreamingFromServer",
|
||||
inputType = io.grpc.benchmarks.proto.Messages.SimpleRequest.class,
|
||||
outputType = io.grpc.benchmarks.proto.Messages.SimpleResponse.class,
|
||||
methodType = io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING)
|
||||
public static io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Messages.SimpleRequest,
|
||||
io.grpc.benchmarks.proto.Messages.SimpleResponse> getStreamingFromServerMethod() {
|
||||
io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Messages.SimpleRequest, io.grpc.benchmarks.proto.Messages.SimpleResponse> getStreamingFromServerMethod;
|
||||
|
|
@ -138,6 +162,12 @@ public final class BenchmarkServiceGrpc {
|
|||
private static volatile io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Messages.SimpleRequest,
|
||||
io.grpc.benchmarks.proto.Messages.SimpleResponse> getStreamingBothWaysMethod;
|
||||
|
||||
@io.grpc.stub.annotations.RpcMethod(
|
||||
fullServiceName = "grpc.testing.BenchmarkService",
|
||||
methodName = "StreamingBothWays",
|
||||
inputType = io.grpc.benchmarks.proto.Messages.SimpleRequest.class,
|
||||
outputType = io.grpc.benchmarks.proto.Messages.SimpleResponse.class,
|
||||
methodType = io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
|
||||
public static io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Messages.SimpleRequest,
|
||||
io.grpc.benchmarks.proto.Messages.SimpleResponse> getStreamingBothWaysMethod() {
|
||||
io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Messages.SimpleRequest, io.grpc.benchmarks.proto.Messages.SimpleResponse> getStreamingBothWaysMethod;
|
||||
|
|
|
|||
|
|
@ -30,6 +30,12 @@ public final class ReportQpsScenarioServiceGrpc {
|
|||
private static volatile io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Control.ScenarioResult,
|
||||
io.grpc.benchmarks.proto.Control.Void> getReportScenarioMethod;
|
||||
|
||||
@io.grpc.stub.annotations.RpcMethod(
|
||||
fullServiceName = "grpc.testing.ReportQpsScenarioService",
|
||||
methodName = "ReportScenario",
|
||||
inputType = io.grpc.benchmarks.proto.Control.ScenarioResult.class,
|
||||
outputType = io.grpc.benchmarks.proto.Control.Void.class,
|
||||
methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
|
||||
public static io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Control.ScenarioResult,
|
||||
io.grpc.benchmarks.proto.Control.Void> getReportScenarioMethod() {
|
||||
io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Control.ScenarioResult, io.grpc.benchmarks.proto.Control.Void> getReportScenarioMethod;
|
||||
|
|
|
|||
|
|
@ -30,6 +30,12 @@ public final class WorkerServiceGrpc {
|
|||
private static volatile io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Control.ServerArgs,
|
||||
io.grpc.benchmarks.proto.Control.ServerStatus> getRunServerMethod;
|
||||
|
||||
@io.grpc.stub.annotations.RpcMethod(
|
||||
fullServiceName = "grpc.testing.WorkerService",
|
||||
methodName = "RunServer",
|
||||
inputType = io.grpc.benchmarks.proto.Control.ServerArgs.class,
|
||||
outputType = io.grpc.benchmarks.proto.Control.ServerStatus.class,
|
||||
methodType = io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
|
||||
public static io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Control.ServerArgs,
|
||||
io.grpc.benchmarks.proto.Control.ServerStatus> getRunServerMethod() {
|
||||
io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Control.ServerArgs, io.grpc.benchmarks.proto.Control.ServerStatus> getRunServerMethod;
|
||||
|
|
@ -57,6 +63,12 @@ public final class WorkerServiceGrpc {
|
|||
private static volatile io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Control.ClientArgs,
|
||||
io.grpc.benchmarks.proto.Control.ClientStatus> getRunClientMethod;
|
||||
|
||||
@io.grpc.stub.annotations.RpcMethod(
|
||||
fullServiceName = "grpc.testing.WorkerService",
|
||||
methodName = "RunClient",
|
||||
inputType = io.grpc.benchmarks.proto.Control.ClientArgs.class,
|
||||
outputType = io.grpc.benchmarks.proto.Control.ClientStatus.class,
|
||||
methodType = io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
|
||||
public static io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Control.ClientArgs,
|
||||
io.grpc.benchmarks.proto.Control.ClientStatus> getRunClientMethod() {
|
||||
io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Control.ClientArgs, io.grpc.benchmarks.proto.Control.ClientStatus> getRunClientMethod;
|
||||
|
|
@ -84,6 +96,12 @@ public final class WorkerServiceGrpc {
|
|||
private static volatile io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Control.CoreRequest,
|
||||
io.grpc.benchmarks.proto.Control.CoreResponse> getCoreCountMethod;
|
||||
|
||||
@io.grpc.stub.annotations.RpcMethod(
|
||||
fullServiceName = "grpc.testing.WorkerService",
|
||||
methodName = "CoreCount",
|
||||
inputType = io.grpc.benchmarks.proto.Control.CoreRequest.class,
|
||||
outputType = io.grpc.benchmarks.proto.Control.CoreResponse.class,
|
||||
methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
|
||||
public static io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Control.CoreRequest,
|
||||
io.grpc.benchmarks.proto.Control.CoreResponse> getCoreCountMethod() {
|
||||
io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Control.CoreRequest, io.grpc.benchmarks.proto.Control.CoreResponse> getCoreCountMethod;
|
||||
|
|
@ -111,6 +129,12 @@ public final class WorkerServiceGrpc {
|
|||
private static volatile io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Control.Void,
|
||||
io.grpc.benchmarks.proto.Control.Void> getQuitWorkerMethod;
|
||||
|
||||
@io.grpc.stub.annotations.RpcMethod(
|
||||
fullServiceName = "grpc.testing.WorkerService",
|
||||
methodName = "QuitWorker",
|
||||
inputType = io.grpc.benchmarks.proto.Control.Void.class,
|
||||
outputType = io.grpc.benchmarks.proto.Control.Void.class,
|
||||
methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
|
||||
public static io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Control.Void,
|
||||
io.grpc.benchmarks.proto.Control.Void> getQuitWorkerMethod() {
|
||||
io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Control.Void, io.grpc.benchmarks.proto.Control.Void> getQuitWorkerMethod;
|
||||
|
|
|
|||
|
|
@ -477,6 +477,12 @@ static void PrintMethodFields(
|
|||
"private static volatile $MethodDescriptor$<$input_type$,\n"
|
||||
" $output_type$> $method_new_field_name$;\n"
|
||||
"\n"
|
||||
"@$RpcMethod$(\n"
|
||||
" fullServiceName = \"$Package$$service_name$\",\n"
|
||||
" methodName = \"$method_name$\",\n"
|
||||
" inputType = $input_type$.class,\n"
|
||||
" outputType = $output_type$.class,\n"
|
||||
" methodType = $MethodType$.$method_type$)\n"
|
||||
"public static $MethodDescriptor$<$input_type$,\n"
|
||||
" $output_type$> $method_method_name$() {\n"
|
||||
" $MethodDescriptor$<$input_type$, $output_type$> $method_new_field_name$;\n"
|
||||
|
|
@ -1275,6 +1281,7 @@ void GenerateService(const ServiceDescriptor* service,
|
|||
vars["ProtoMethodDescriptorSupplier"] =
|
||||
"io.grpc.protobuf.ProtoMethodDescriptorSupplier";
|
||||
vars["AbstractStub"] = "io.grpc.stub.AbstractStub";
|
||||
vars["RpcMethod"] = "io.grpc.stub.annotations.RpcMethod";
|
||||
vars["MethodDescriptor"] = "io.grpc.MethodDescriptor";
|
||||
vars["NanoUtils"] = "io.grpc.protobuf.nano.NanoUtils";
|
||||
vars["StreamObserver"] = "io.grpc.stub.StreamObserver";
|
||||
|
|
|
|||
|
|
@ -33,6 +33,12 @@ public final class TestServiceGrpc {
|
|||
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.SimpleRequest,
|
||||
io.grpc.testing.compiler.Test.SimpleResponse> getUnaryCallMethod;
|
||||
|
||||
@io.grpc.stub.annotations.RpcMethod(
|
||||
fullServiceName = "grpc.testing.compiler.TestService",
|
||||
methodName = "UnaryCall",
|
||||
inputType = io.grpc.testing.compiler.Test.SimpleRequest.class,
|
||||
outputType = io.grpc.testing.compiler.Test.SimpleResponse.class,
|
||||
methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
|
||||
public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.SimpleRequest,
|
||||
io.grpc.testing.compiler.Test.SimpleResponse> getUnaryCallMethod() {
|
||||
io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.SimpleRequest, io.grpc.testing.compiler.Test.SimpleResponse> getUnaryCallMethod;
|
||||
|
|
@ -60,6 +66,12 @@ public final class TestServiceGrpc {
|
|||
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
|
||||
io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getStreamingOutputCallMethod;
|
||||
|
||||
@io.grpc.stub.annotations.RpcMethod(
|
||||
fullServiceName = "grpc.testing.compiler.TestService",
|
||||
methodName = "StreamingOutputCall",
|
||||
inputType = io.grpc.testing.compiler.Test.StreamingOutputCallRequest.class,
|
||||
outputType = io.grpc.testing.compiler.Test.StreamingOutputCallResponse.class,
|
||||
methodType = io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING)
|
||||
public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
|
||||
io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getStreamingOutputCallMethod() {
|
||||
io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest, io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getStreamingOutputCallMethod;
|
||||
|
|
@ -87,6 +99,12 @@ public final class TestServiceGrpc {
|
|||
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingInputCallRequest,
|
||||
io.grpc.testing.compiler.Test.StreamingInputCallResponse> getStreamingInputCallMethod;
|
||||
|
||||
@io.grpc.stub.annotations.RpcMethod(
|
||||
fullServiceName = "grpc.testing.compiler.TestService",
|
||||
methodName = "StreamingInputCall",
|
||||
inputType = io.grpc.testing.compiler.Test.StreamingInputCallRequest.class,
|
||||
outputType = io.grpc.testing.compiler.Test.StreamingInputCallResponse.class,
|
||||
methodType = io.grpc.MethodDescriptor.MethodType.CLIENT_STREAMING)
|
||||
public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingInputCallRequest,
|
||||
io.grpc.testing.compiler.Test.StreamingInputCallResponse> getStreamingInputCallMethod() {
|
||||
io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingInputCallRequest, io.grpc.testing.compiler.Test.StreamingInputCallResponse> getStreamingInputCallMethod;
|
||||
|
|
@ -114,6 +132,12 @@ public final class TestServiceGrpc {
|
|||
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
|
||||
io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getFullBidiCallMethod;
|
||||
|
||||
@io.grpc.stub.annotations.RpcMethod(
|
||||
fullServiceName = "grpc.testing.compiler.TestService",
|
||||
methodName = "FullBidiCall",
|
||||
inputType = io.grpc.testing.compiler.Test.StreamingOutputCallRequest.class,
|
||||
outputType = io.grpc.testing.compiler.Test.StreamingOutputCallResponse.class,
|
||||
methodType = io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
|
||||
public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
|
||||
io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getFullBidiCallMethod() {
|
||||
io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest, io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getFullBidiCallMethod;
|
||||
|
|
@ -141,6 +165,12 @@ public final class TestServiceGrpc {
|
|||
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
|
||||
io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getHalfBidiCallMethod;
|
||||
|
||||
@io.grpc.stub.annotations.RpcMethod(
|
||||
fullServiceName = "grpc.testing.compiler.TestService",
|
||||
methodName = "HalfBidiCall",
|
||||
inputType = io.grpc.testing.compiler.Test.StreamingOutputCallRequest.class,
|
||||
outputType = io.grpc.testing.compiler.Test.StreamingOutputCallResponse.class,
|
||||
methodType = io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
|
||||
public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
|
||||
io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getHalfBidiCallMethod() {
|
||||
io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest, io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getHalfBidiCallMethod;
|
||||
|
|
@ -168,6 +198,12 @@ public final class TestServiceGrpc {
|
|||
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingInputCallRequest,
|
||||
io.grpc.testing.compiler.Test.StreamingInputCallResponse> getImportMethod;
|
||||
|
||||
@io.grpc.stub.annotations.RpcMethod(
|
||||
fullServiceName = "grpc.testing.compiler.TestService",
|
||||
methodName = "Import",
|
||||
inputType = io.grpc.testing.compiler.Test.StreamingInputCallRequest.class,
|
||||
outputType = io.grpc.testing.compiler.Test.StreamingInputCallResponse.class,
|
||||
methodType = io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
|
||||
public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingInputCallRequest,
|
||||
io.grpc.testing.compiler.Test.StreamingInputCallResponse> getImportMethod() {
|
||||
io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingInputCallRequest, io.grpc.testing.compiler.Test.StreamingInputCallResponse> getImportMethod;
|
||||
|
|
|
|||
|
|
@ -33,6 +33,12 @@ public final class TestServiceGrpc {
|
|||
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.SimpleRequest,
|
||||
io.grpc.testing.compiler.Test.SimpleResponse> getUnaryCallMethod;
|
||||
|
||||
@io.grpc.stub.annotations.RpcMethod(
|
||||
fullServiceName = "grpc.testing.compiler.TestService",
|
||||
methodName = "UnaryCall",
|
||||
inputType = io.grpc.testing.compiler.Test.SimpleRequest.class,
|
||||
outputType = io.grpc.testing.compiler.Test.SimpleResponse.class,
|
||||
methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
|
||||
public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.SimpleRequest,
|
||||
io.grpc.testing.compiler.Test.SimpleResponse> getUnaryCallMethod() {
|
||||
io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.SimpleRequest, io.grpc.testing.compiler.Test.SimpleResponse> getUnaryCallMethod;
|
||||
|
|
@ -59,6 +65,12 @@ public final class TestServiceGrpc {
|
|||
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
|
||||
io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getStreamingOutputCallMethod;
|
||||
|
||||
@io.grpc.stub.annotations.RpcMethod(
|
||||
fullServiceName = "grpc.testing.compiler.TestService",
|
||||
methodName = "StreamingOutputCall",
|
||||
inputType = io.grpc.testing.compiler.Test.StreamingOutputCallRequest.class,
|
||||
outputType = io.grpc.testing.compiler.Test.StreamingOutputCallResponse.class,
|
||||
methodType = io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING)
|
||||
public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
|
||||
io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getStreamingOutputCallMethod() {
|
||||
io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest, io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getStreamingOutputCallMethod;
|
||||
|
|
@ -85,6 +97,12 @@ public final class TestServiceGrpc {
|
|||
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingInputCallRequest,
|
||||
io.grpc.testing.compiler.Test.StreamingInputCallResponse> getStreamingInputCallMethod;
|
||||
|
||||
@io.grpc.stub.annotations.RpcMethod(
|
||||
fullServiceName = "grpc.testing.compiler.TestService",
|
||||
methodName = "StreamingInputCall",
|
||||
inputType = io.grpc.testing.compiler.Test.StreamingInputCallRequest.class,
|
||||
outputType = io.grpc.testing.compiler.Test.StreamingInputCallResponse.class,
|
||||
methodType = io.grpc.MethodDescriptor.MethodType.CLIENT_STREAMING)
|
||||
public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingInputCallRequest,
|
||||
io.grpc.testing.compiler.Test.StreamingInputCallResponse> getStreamingInputCallMethod() {
|
||||
io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingInputCallRequest, io.grpc.testing.compiler.Test.StreamingInputCallResponse> getStreamingInputCallMethod;
|
||||
|
|
@ -111,6 +129,12 @@ public final class TestServiceGrpc {
|
|||
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
|
||||
io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getFullBidiCallMethod;
|
||||
|
||||
@io.grpc.stub.annotations.RpcMethod(
|
||||
fullServiceName = "grpc.testing.compiler.TestService",
|
||||
methodName = "FullBidiCall",
|
||||
inputType = io.grpc.testing.compiler.Test.StreamingOutputCallRequest.class,
|
||||
outputType = io.grpc.testing.compiler.Test.StreamingOutputCallResponse.class,
|
||||
methodType = io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
|
||||
public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
|
||||
io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getFullBidiCallMethod() {
|
||||
io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest, io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getFullBidiCallMethod;
|
||||
|
|
@ -137,6 +161,12 @@ public final class TestServiceGrpc {
|
|||
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
|
||||
io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getHalfBidiCallMethod;
|
||||
|
||||
@io.grpc.stub.annotations.RpcMethod(
|
||||
fullServiceName = "grpc.testing.compiler.TestService",
|
||||
methodName = "HalfBidiCall",
|
||||
inputType = io.grpc.testing.compiler.Test.StreamingOutputCallRequest.class,
|
||||
outputType = io.grpc.testing.compiler.Test.StreamingOutputCallResponse.class,
|
||||
methodType = io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
|
||||
public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
|
||||
io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getHalfBidiCallMethod() {
|
||||
io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest, io.grpc.testing.compiler.Test.StreamingOutputCallResponse> getHalfBidiCallMethod;
|
||||
|
|
@ -163,6 +193,12 @@ public final class TestServiceGrpc {
|
|||
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingInputCallRequest,
|
||||
io.grpc.testing.compiler.Test.StreamingInputCallResponse> getImportMethod;
|
||||
|
||||
@io.grpc.stub.annotations.RpcMethod(
|
||||
fullServiceName = "grpc.testing.compiler.TestService",
|
||||
methodName = "Import",
|
||||
inputType = io.grpc.testing.compiler.Test.StreamingInputCallRequest.class,
|
||||
outputType = io.grpc.testing.compiler.Test.StreamingInputCallResponse.class,
|
||||
methodType = io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
|
||||
public static io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingInputCallRequest,
|
||||
io.grpc.testing.compiler.Test.StreamingInputCallResponse> getImportMethod() {
|
||||
io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingInputCallRequest, io.grpc.testing.compiler.Test.StreamingInputCallResponse> getImportMethod;
|
||||
|
|
|
|||
|
|
@ -30,6 +30,12 @@ public final class LoadBalancerGrpc {
|
|||
private static volatile io.grpc.MethodDescriptor<io.grpc.grpclb.LoadBalanceRequest,
|
||||
io.grpc.grpclb.LoadBalanceResponse> getBalanceLoadMethod;
|
||||
|
||||
@io.grpc.stub.annotations.RpcMethod(
|
||||
fullServiceName = "grpc.lb.v1.LoadBalancer",
|
||||
methodName = "BalanceLoad",
|
||||
inputType = io.grpc.grpclb.LoadBalanceRequest.class,
|
||||
outputType = io.grpc.grpclb.LoadBalanceResponse.class,
|
||||
methodType = io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
|
||||
public static io.grpc.MethodDescriptor<io.grpc.grpclb.LoadBalanceRequest,
|
||||
io.grpc.grpclb.LoadBalanceResponse> getBalanceLoadMethod() {
|
||||
io.grpc.MethodDescriptor<io.grpc.grpclb.LoadBalanceRequest, io.grpc.grpclb.LoadBalanceResponse> getBalanceLoadMethod;
|
||||
|
|
|
|||
|
|
@ -30,6 +30,12 @@ public final class MetricsServiceGrpc {
|
|||
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.integration.Metrics.EmptyMessage,
|
||||
io.grpc.testing.integration.Metrics.GaugeResponse> getGetAllGaugesMethod;
|
||||
|
||||
@io.grpc.stub.annotations.RpcMethod(
|
||||
fullServiceName = "grpc.testing.MetricsService",
|
||||
methodName = "GetAllGauges",
|
||||
inputType = io.grpc.testing.integration.Metrics.EmptyMessage.class,
|
||||
outputType = io.grpc.testing.integration.Metrics.GaugeResponse.class,
|
||||
methodType = io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING)
|
||||
public static io.grpc.MethodDescriptor<io.grpc.testing.integration.Metrics.EmptyMessage,
|
||||
io.grpc.testing.integration.Metrics.GaugeResponse> getGetAllGaugesMethod() {
|
||||
io.grpc.MethodDescriptor<io.grpc.testing.integration.Metrics.EmptyMessage, io.grpc.testing.integration.Metrics.GaugeResponse> getGetAllGaugesMethod;
|
||||
|
|
@ -57,6 +63,12 @@ public final class MetricsServiceGrpc {
|
|||
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.integration.Metrics.GaugeRequest,
|
||||
io.grpc.testing.integration.Metrics.GaugeResponse> getGetGaugeMethod;
|
||||
|
||||
@io.grpc.stub.annotations.RpcMethod(
|
||||
fullServiceName = "grpc.testing.MetricsService",
|
||||
methodName = "GetGauge",
|
||||
inputType = io.grpc.testing.integration.Metrics.GaugeRequest.class,
|
||||
outputType = io.grpc.testing.integration.Metrics.GaugeResponse.class,
|
||||
methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
|
||||
public static io.grpc.MethodDescriptor<io.grpc.testing.integration.Metrics.GaugeRequest,
|
||||
io.grpc.testing.integration.Metrics.GaugeResponse> getGetGaugeMethod() {
|
||||
io.grpc.MethodDescriptor<io.grpc.testing.integration.Metrics.GaugeRequest, io.grpc.testing.integration.Metrics.GaugeResponse> getGetGaugeMethod;
|
||||
|
|
|
|||
|
|
@ -33,6 +33,12 @@ public final class ReconnectServiceGrpc {
|
|||
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.integration.EmptyProtos.Empty,
|
||||
io.grpc.testing.integration.EmptyProtos.Empty> getStartMethod;
|
||||
|
||||
@io.grpc.stub.annotations.RpcMethod(
|
||||
fullServiceName = "grpc.testing.ReconnectService",
|
||||
methodName = "Start",
|
||||
inputType = io.grpc.testing.integration.EmptyProtos.Empty.class,
|
||||
outputType = io.grpc.testing.integration.EmptyProtos.Empty.class,
|
||||
methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
|
||||
public static io.grpc.MethodDescriptor<io.grpc.testing.integration.EmptyProtos.Empty,
|
||||
io.grpc.testing.integration.EmptyProtos.Empty> getStartMethod() {
|
||||
io.grpc.MethodDescriptor<io.grpc.testing.integration.EmptyProtos.Empty, io.grpc.testing.integration.EmptyProtos.Empty> getStartMethod;
|
||||
|
|
@ -60,6 +66,12 @@ public final class ReconnectServiceGrpc {
|
|||
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.integration.EmptyProtos.Empty,
|
||||
io.grpc.testing.integration.Messages.ReconnectInfo> getStopMethod;
|
||||
|
||||
@io.grpc.stub.annotations.RpcMethod(
|
||||
fullServiceName = "grpc.testing.ReconnectService",
|
||||
methodName = "Stop",
|
||||
inputType = io.grpc.testing.integration.EmptyProtos.Empty.class,
|
||||
outputType = io.grpc.testing.integration.Messages.ReconnectInfo.class,
|
||||
methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
|
||||
public static io.grpc.MethodDescriptor<io.grpc.testing.integration.EmptyProtos.Empty,
|
||||
io.grpc.testing.integration.Messages.ReconnectInfo> getStopMethod() {
|
||||
io.grpc.MethodDescriptor<io.grpc.testing.integration.EmptyProtos.Empty, io.grpc.testing.integration.Messages.ReconnectInfo> getStopMethod;
|
||||
|
|
|
|||
|
|
@ -34,6 +34,12 @@ public final class TestServiceGrpc {
|
|||
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.integration.EmptyProtos.Empty,
|
||||
io.grpc.testing.integration.EmptyProtos.Empty> getEmptyCallMethod;
|
||||
|
||||
@io.grpc.stub.annotations.RpcMethod(
|
||||
fullServiceName = "grpc.testing.TestService",
|
||||
methodName = "EmptyCall",
|
||||
inputType = io.grpc.testing.integration.EmptyProtos.Empty.class,
|
||||
outputType = io.grpc.testing.integration.EmptyProtos.Empty.class,
|
||||
methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
|
||||
public static io.grpc.MethodDescriptor<io.grpc.testing.integration.EmptyProtos.Empty,
|
||||
io.grpc.testing.integration.EmptyProtos.Empty> getEmptyCallMethod() {
|
||||
io.grpc.MethodDescriptor<io.grpc.testing.integration.EmptyProtos.Empty, io.grpc.testing.integration.EmptyProtos.Empty> getEmptyCallMethod;
|
||||
|
|
@ -61,6 +67,12 @@ public final class TestServiceGrpc {
|
|||
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.SimpleRequest,
|
||||
io.grpc.testing.integration.Messages.SimpleResponse> getUnaryCallMethod;
|
||||
|
||||
@io.grpc.stub.annotations.RpcMethod(
|
||||
fullServiceName = "grpc.testing.TestService",
|
||||
methodName = "UnaryCall",
|
||||
inputType = io.grpc.testing.integration.Messages.SimpleRequest.class,
|
||||
outputType = io.grpc.testing.integration.Messages.SimpleResponse.class,
|
||||
methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
|
||||
public static io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.SimpleRequest,
|
||||
io.grpc.testing.integration.Messages.SimpleResponse> getUnaryCallMethod() {
|
||||
io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.SimpleRequest, io.grpc.testing.integration.Messages.SimpleResponse> getUnaryCallMethod;
|
||||
|
|
@ -88,6 +100,12 @@ public final class TestServiceGrpc {
|
|||
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.SimpleRequest,
|
||||
io.grpc.testing.integration.Messages.SimpleResponse> getCacheableUnaryCallMethod;
|
||||
|
||||
@io.grpc.stub.annotations.RpcMethod(
|
||||
fullServiceName = "grpc.testing.TestService",
|
||||
methodName = "CacheableUnaryCall",
|
||||
inputType = io.grpc.testing.integration.Messages.SimpleRequest.class,
|
||||
outputType = io.grpc.testing.integration.Messages.SimpleResponse.class,
|
||||
methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
|
||||
public static io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.SimpleRequest,
|
||||
io.grpc.testing.integration.Messages.SimpleResponse> getCacheableUnaryCallMethod() {
|
||||
io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.SimpleRequest, io.grpc.testing.integration.Messages.SimpleResponse> getCacheableUnaryCallMethod;
|
||||
|
|
@ -115,6 +133,12 @@ public final class TestServiceGrpc {
|
|||
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.StreamingOutputCallRequest,
|
||||
io.grpc.testing.integration.Messages.StreamingOutputCallResponse> getStreamingOutputCallMethod;
|
||||
|
||||
@io.grpc.stub.annotations.RpcMethod(
|
||||
fullServiceName = "grpc.testing.TestService",
|
||||
methodName = "StreamingOutputCall",
|
||||
inputType = io.grpc.testing.integration.Messages.StreamingOutputCallRequest.class,
|
||||
outputType = io.grpc.testing.integration.Messages.StreamingOutputCallResponse.class,
|
||||
methodType = io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING)
|
||||
public static io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.StreamingOutputCallRequest,
|
||||
io.grpc.testing.integration.Messages.StreamingOutputCallResponse> getStreamingOutputCallMethod() {
|
||||
io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.StreamingOutputCallRequest, io.grpc.testing.integration.Messages.StreamingOutputCallResponse> getStreamingOutputCallMethod;
|
||||
|
|
@ -142,6 +166,12 @@ public final class TestServiceGrpc {
|
|||
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.StreamingInputCallRequest,
|
||||
io.grpc.testing.integration.Messages.StreamingInputCallResponse> getStreamingInputCallMethod;
|
||||
|
||||
@io.grpc.stub.annotations.RpcMethod(
|
||||
fullServiceName = "grpc.testing.TestService",
|
||||
methodName = "StreamingInputCall",
|
||||
inputType = io.grpc.testing.integration.Messages.StreamingInputCallRequest.class,
|
||||
outputType = io.grpc.testing.integration.Messages.StreamingInputCallResponse.class,
|
||||
methodType = io.grpc.MethodDescriptor.MethodType.CLIENT_STREAMING)
|
||||
public static io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.StreamingInputCallRequest,
|
||||
io.grpc.testing.integration.Messages.StreamingInputCallResponse> getStreamingInputCallMethod() {
|
||||
io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.StreamingInputCallRequest, io.grpc.testing.integration.Messages.StreamingInputCallResponse> getStreamingInputCallMethod;
|
||||
|
|
@ -169,6 +199,12 @@ public final class TestServiceGrpc {
|
|||
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.StreamingOutputCallRequest,
|
||||
io.grpc.testing.integration.Messages.StreamingOutputCallResponse> getFullDuplexCallMethod;
|
||||
|
||||
@io.grpc.stub.annotations.RpcMethod(
|
||||
fullServiceName = "grpc.testing.TestService",
|
||||
methodName = "FullDuplexCall",
|
||||
inputType = io.grpc.testing.integration.Messages.StreamingOutputCallRequest.class,
|
||||
outputType = io.grpc.testing.integration.Messages.StreamingOutputCallResponse.class,
|
||||
methodType = io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
|
||||
public static io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.StreamingOutputCallRequest,
|
||||
io.grpc.testing.integration.Messages.StreamingOutputCallResponse> getFullDuplexCallMethod() {
|
||||
io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.StreamingOutputCallRequest, io.grpc.testing.integration.Messages.StreamingOutputCallResponse> getFullDuplexCallMethod;
|
||||
|
|
@ -196,6 +232,12 @@ public final class TestServiceGrpc {
|
|||
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.StreamingOutputCallRequest,
|
||||
io.grpc.testing.integration.Messages.StreamingOutputCallResponse> getHalfDuplexCallMethod;
|
||||
|
||||
@io.grpc.stub.annotations.RpcMethod(
|
||||
fullServiceName = "grpc.testing.TestService",
|
||||
methodName = "HalfDuplexCall",
|
||||
inputType = io.grpc.testing.integration.Messages.StreamingOutputCallRequest.class,
|
||||
outputType = io.grpc.testing.integration.Messages.StreamingOutputCallResponse.class,
|
||||
methodType = io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
|
||||
public static io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.StreamingOutputCallRequest,
|
||||
io.grpc.testing.integration.Messages.StreamingOutputCallResponse> getHalfDuplexCallMethod() {
|
||||
io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.StreamingOutputCallRequest, io.grpc.testing.integration.Messages.StreamingOutputCallResponse> getHalfDuplexCallMethod;
|
||||
|
|
@ -223,6 +265,12 @@ public final class TestServiceGrpc {
|
|||
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.integration.EmptyProtos.Empty,
|
||||
io.grpc.testing.integration.EmptyProtos.Empty> getUnimplementedCallMethod;
|
||||
|
||||
@io.grpc.stub.annotations.RpcMethod(
|
||||
fullServiceName = "grpc.testing.TestService",
|
||||
methodName = "UnimplementedCall",
|
||||
inputType = io.grpc.testing.integration.EmptyProtos.Empty.class,
|
||||
outputType = io.grpc.testing.integration.EmptyProtos.Empty.class,
|
||||
methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
|
||||
public static io.grpc.MethodDescriptor<io.grpc.testing.integration.EmptyProtos.Empty,
|
||||
io.grpc.testing.integration.EmptyProtos.Empty> getUnimplementedCallMethod() {
|
||||
io.grpc.MethodDescriptor<io.grpc.testing.integration.EmptyProtos.Empty, io.grpc.testing.integration.EmptyProtos.Empty> getUnimplementedCallMethod;
|
||||
|
|
|
|||
|
|
@ -34,6 +34,12 @@ public final class UnimplementedServiceGrpc {
|
|||
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.integration.EmptyProtos.Empty,
|
||||
io.grpc.testing.integration.EmptyProtos.Empty> getUnimplementedCallMethod;
|
||||
|
||||
@io.grpc.stub.annotations.RpcMethod(
|
||||
fullServiceName = "grpc.testing.UnimplementedService",
|
||||
methodName = "UnimplementedCall",
|
||||
inputType = io.grpc.testing.integration.EmptyProtos.Empty.class,
|
||||
outputType = io.grpc.testing.integration.EmptyProtos.Empty.class,
|
||||
methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
|
||||
public static io.grpc.MethodDescriptor<io.grpc.testing.integration.EmptyProtos.Empty,
|
||||
io.grpc.testing.integration.EmptyProtos.Empty> getUnimplementedCallMethod() {
|
||||
io.grpc.MethodDescriptor<io.grpc.testing.integration.EmptyProtos.Empty, io.grpc.testing.integration.EmptyProtos.Empty> getUnimplementedCallMethod;
|
||||
|
|
|
|||
|
|
@ -34,6 +34,12 @@ public final class ChannelzGrpc {
|
|||
private static volatile io.grpc.MethodDescriptor<io.grpc.channelz.v1.GetTopChannelsRequest,
|
||||
io.grpc.channelz.v1.GetTopChannelsResponse> getGetTopChannelsMethod;
|
||||
|
||||
@io.grpc.stub.annotations.RpcMethod(
|
||||
fullServiceName = "grpc.channelz.v1.Channelz",
|
||||
methodName = "GetTopChannels",
|
||||
inputType = io.grpc.channelz.v1.GetTopChannelsRequest.class,
|
||||
outputType = io.grpc.channelz.v1.GetTopChannelsResponse.class,
|
||||
methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
|
||||
public static io.grpc.MethodDescriptor<io.grpc.channelz.v1.GetTopChannelsRequest,
|
||||
io.grpc.channelz.v1.GetTopChannelsResponse> getGetTopChannelsMethod() {
|
||||
io.grpc.MethodDescriptor<io.grpc.channelz.v1.GetTopChannelsRequest, io.grpc.channelz.v1.GetTopChannelsResponse> getGetTopChannelsMethod;
|
||||
|
|
@ -61,6 +67,12 @@ public final class ChannelzGrpc {
|
|||
private static volatile io.grpc.MethodDescriptor<io.grpc.channelz.v1.GetServersRequest,
|
||||
io.grpc.channelz.v1.GetServersResponse> getGetServersMethod;
|
||||
|
||||
@io.grpc.stub.annotations.RpcMethod(
|
||||
fullServiceName = "grpc.channelz.v1.Channelz",
|
||||
methodName = "GetServers",
|
||||
inputType = io.grpc.channelz.v1.GetServersRequest.class,
|
||||
outputType = io.grpc.channelz.v1.GetServersResponse.class,
|
||||
methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
|
||||
public static io.grpc.MethodDescriptor<io.grpc.channelz.v1.GetServersRequest,
|
||||
io.grpc.channelz.v1.GetServersResponse> getGetServersMethod() {
|
||||
io.grpc.MethodDescriptor<io.grpc.channelz.v1.GetServersRequest, io.grpc.channelz.v1.GetServersResponse> getGetServersMethod;
|
||||
|
|
@ -88,6 +100,12 @@ public final class ChannelzGrpc {
|
|||
private static volatile io.grpc.MethodDescriptor<io.grpc.channelz.v1.GetServerSocketsRequest,
|
||||
io.grpc.channelz.v1.GetServerSocketsResponse> getGetServerSocketsMethod;
|
||||
|
||||
@io.grpc.stub.annotations.RpcMethod(
|
||||
fullServiceName = "grpc.channelz.v1.Channelz",
|
||||
methodName = "GetServerSockets",
|
||||
inputType = io.grpc.channelz.v1.GetServerSocketsRequest.class,
|
||||
outputType = io.grpc.channelz.v1.GetServerSocketsResponse.class,
|
||||
methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
|
||||
public static io.grpc.MethodDescriptor<io.grpc.channelz.v1.GetServerSocketsRequest,
|
||||
io.grpc.channelz.v1.GetServerSocketsResponse> getGetServerSocketsMethod() {
|
||||
io.grpc.MethodDescriptor<io.grpc.channelz.v1.GetServerSocketsRequest, io.grpc.channelz.v1.GetServerSocketsResponse> getGetServerSocketsMethod;
|
||||
|
|
@ -115,6 +133,12 @@ public final class ChannelzGrpc {
|
|||
private static volatile io.grpc.MethodDescriptor<io.grpc.channelz.v1.GetChannelRequest,
|
||||
io.grpc.channelz.v1.GetChannelResponse> getGetChannelMethod;
|
||||
|
||||
@io.grpc.stub.annotations.RpcMethod(
|
||||
fullServiceName = "grpc.channelz.v1.Channelz",
|
||||
methodName = "GetChannel",
|
||||
inputType = io.grpc.channelz.v1.GetChannelRequest.class,
|
||||
outputType = io.grpc.channelz.v1.GetChannelResponse.class,
|
||||
methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
|
||||
public static io.grpc.MethodDescriptor<io.grpc.channelz.v1.GetChannelRequest,
|
||||
io.grpc.channelz.v1.GetChannelResponse> getGetChannelMethod() {
|
||||
io.grpc.MethodDescriptor<io.grpc.channelz.v1.GetChannelRequest, io.grpc.channelz.v1.GetChannelResponse> getGetChannelMethod;
|
||||
|
|
@ -142,6 +166,12 @@ public final class ChannelzGrpc {
|
|||
private static volatile io.grpc.MethodDescriptor<io.grpc.channelz.v1.GetSubchannelRequest,
|
||||
io.grpc.channelz.v1.GetSubchannelResponse> getGetSubchannelMethod;
|
||||
|
||||
@io.grpc.stub.annotations.RpcMethod(
|
||||
fullServiceName = "grpc.channelz.v1.Channelz",
|
||||
methodName = "GetSubchannel",
|
||||
inputType = io.grpc.channelz.v1.GetSubchannelRequest.class,
|
||||
outputType = io.grpc.channelz.v1.GetSubchannelResponse.class,
|
||||
methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
|
||||
public static io.grpc.MethodDescriptor<io.grpc.channelz.v1.GetSubchannelRequest,
|
||||
io.grpc.channelz.v1.GetSubchannelResponse> getGetSubchannelMethod() {
|
||||
io.grpc.MethodDescriptor<io.grpc.channelz.v1.GetSubchannelRequest, io.grpc.channelz.v1.GetSubchannelResponse> getGetSubchannelMethod;
|
||||
|
|
@ -169,6 +199,12 @@ public final class ChannelzGrpc {
|
|||
private static volatile io.grpc.MethodDescriptor<io.grpc.channelz.v1.GetSocketRequest,
|
||||
io.grpc.channelz.v1.GetSocketResponse> getGetSocketMethod;
|
||||
|
||||
@io.grpc.stub.annotations.RpcMethod(
|
||||
fullServiceName = "grpc.channelz.v1.Channelz",
|
||||
methodName = "GetSocket",
|
||||
inputType = io.grpc.channelz.v1.GetSocketRequest.class,
|
||||
outputType = io.grpc.channelz.v1.GetSocketResponse.class,
|
||||
methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
|
||||
public static io.grpc.MethodDescriptor<io.grpc.channelz.v1.GetSocketRequest,
|
||||
io.grpc.channelz.v1.GetSocketResponse> getGetSocketMethod() {
|
||||
io.grpc.MethodDescriptor<io.grpc.channelz.v1.GetSocketRequest, io.grpc.channelz.v1.GetSocketResponse> getGetSocketMethod;
|
||||
|
|
|
|||
|
|
@ -30,6 +30,12 @@ public final class HealthGrpc {
|
|||
private static volatile io.grpc.MethodDescriptor<io.grpc.health.v1.HealthCheckRequest,
|
||||
io.grpc.health.v1.HealthCheckResponse> getCheckMethod;
|
||||
|
||||
@io.grpc.stub.annotations.RpcMethod(
|
||||
fullServiceName = "grpc.health.v1.Health",
|
||||
methodName = "Check",
|
||||
inputType = io.grpc.health.v1.HealthCheckRequest.class,
|
||||
outputType = io.grpc.health.v1.HealthCheckResponse.class,
|
||||
methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
|
||||
public static io.grpc.MethodDescriptor<io.grpc.health.v1.HealthCheckRequest,
|
||||
io.grpc.health.v1.HealthCheckResponse> getCheckMethod() {
|
||||
io.grpc.MethodDescriptor<io.grpc.health.v1.HealthCheckRequest, io.grpc.health.v1.HealthCheckResponse> getCheckMethod;
|
||||
|
|
|
|||
|
|
@ -30,6 +30,12 @@ public final class ServerReflectionGrpc {
|
|||
private static volatile io.grpc.MethodDescriptor<io.grpc.reflection.v1alpha.ServerReflectionRequest,
|
||||
io.grpc.reflection.v1alpha.ServerReflectionResponse> getServerReflectionInfoMethod;
|
||||
|
||||
@io.grpc.stub.annotations.RpcMethod(
|
||||
fullServiceName = "grpc.reflection.v1alpha.ServerReflection",
|
||||
methodName = "ServerReflectionInfo",
|
||||
inputType = io.grpc.reflection.v1alpha.ServerReflectionRequest.class,
|
||||
outputType = io.grpc.reflection.v1alpha.ServerReflectionResponse.class,
|
||||
methodType = io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
|
||||
public static io.grpc.MethodDescriptor<io.grpc.reflection.v1alpha.ServerReflectionRequest,
|
||||
io.grpc.reflection.v1alpha.ServerReflectionResponse> getServerReflectionInfoMethod() {
|
||||
io.grpc.MethodDescriptor<io.grpc.reflection.v1alpha.ServerReflectionRequest, io.grpc.reflection.v1alpha.ServerReflectionResponse> getServerReflectionInfoMethod;
|
||||
|
|
|
|||
|
|
@ -33,6 +33,12 @@ public final class AnotherDynamicServiceGrpc {
|
|||
private static volatile io.grpc.MethodDescriptor<io.grpc.reflection.testing.DynamicRequest,
|
||||
io.grpc.reflection.testing.DynamicReply> getMethodMethod;
|
||||
|
||||
@io.grpc.stub.annotations.RpcMethod(
|
||||
fullServiceName = "grpc.reflection.testing.AnotherDynamicService",
|
||||
methodName = "Method",
|
||||
inputType = io.grpc.reflection.testing.DynamicRequest.class,
|
||||
outputType = io.grpc.reflection.testing.DynamicReply.class,
|
||||
methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
|
||||
public static io.grpc.MethodDescriptor<io.grpc.reflection.testing.DynamicRequest,
|
||||
io.grpc.reflection.testing.DynamicReply> getMethodMethod() {
|
||||
io.grpc.MethodDescriptor<io.grpc.reflection.testing.DynamicRequest, io.grpc.reflection.testing.DynamicReply> getMethodMethod;
|
||||
|
|
|
|||
|
|
@ -33,6 +33,12 @@ public final class DynamicServiceGrpc {
|
|||
private static volatile io.grpc.MethodDescriptor<io.grpc.reflection.testing.DynamicRequest,
|
||||
io.grpc.reflection.testing.DynamicReply> getMethodMethod;
|
||||
|
||||
@io.grpc.stub.annotations.RpcMethod(
|
||||
fullServiceName = "grpc.reflection.testing.DynamicService",
|
||||
methodName = "Method",
|
||||
inputType = io.grpc.reflection.testing.DynamicRequest.class,
|
||||
outputType = io.grpc.reflection.testing.DynamicReply.class,
|
||||
methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
|
||||
public static io.grpc.MethodDescriptor<io.grpc.reflection.testing.DynamicRequest,
|
||||
io.grpc.reflection.testing.DynamicReply> getMethodMethod() {
|
||||
io.grpc.MethodDescriptor<io.grpc.reflection.testing.DynamicRequest, io.grpc.reflection.testing.DynamicReply> getMethodMethod;
|
||||
|
|
|
|||
|
|
@ -30,6 +30,12 @@ public final class ReflectableServiceGrpc {
|
|||
private static volatile io.grpc.MethodDescriptor<io.grpc.reflection.testing.Request,
|
||||
io.grpc.reflection.testing.Reply> getMethodMethod;
|
||||
|
||||
@io.grpc.stub.annotations.RpcMethod(
|
||||
fullServiceName = "grpc.reflection.testing.ReflectableService",
|
||||
methodName = "Method",
|
||||
inputType = io.grpc.reflection.testing.Request.class,
|
||||
outputType = io.grpc.reflection.testing.Reply.class,
|
||||
methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
|
||||
public static io.grpc.MethodDescriptor<io.grpc.reflection.testing.Request,
|
||||
io.grpc.reflection.testing.Reply> getMethodMethod() {
|
||||
io.grpc.MethodDescriptor<io.grpc.reflection.testing.Request, io.grpc.reflection.testing.Reply> getMethodMethod;
|
||||
|
|
|
|||
|
|
@ -0,0 +1,56 @@
|
|||
/*
|
||||
* Copyright 2018 The gRPC Authors
|
||||
*
|
||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||
* you may not use this file except in compliance with the License.
|
||||
* You may obtain a copy of the License at
|
||||
*
|
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
*
|
||||
* Unless required by applicable law or agreed to in writing, software
|
||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
*/
|
||||
|
||||
package io.grpc.stub.annotations;
|
||||
|
||||
import io.grpc.MethodDescriptor.MethodType;
|
||||
import java.lang.annotation.ElementType;
|
||||
import java.lang.annotation.Retention;
|
||||
import java.lang.annotation.RetentionPolicy;
|
||||
import java.lang.annotation.Target;
|
||||
|
||||
/**
|
||||
* Annotates a method descriptor method to provide metadata for annotation processing.
|
||||
*/
|
||||
@Retention(RetentionPolicy.CLASS)
|
||||
@Target(ElementType.METHOD)
|
||||
public @interface RpcMethod {
|
||||
|
||||
/**
|
||||
* The full service name for the method
|
||||
*/
|
||||
String fullServiceName();
|
||||
|
||||
/**
|
||||
* The method name for the method
|
||||
*/
|
||||
String methodName();
|
||||
|
||||
/**
|
||||
* The input type of the method
|
||||
*/
|
||||
Class<?> inputType();
|
||||
|
||||
/**
|
||||
* The output type of the method
|
||||
*/
|
||||
Class<?> outputType();
|
||||
|
||||
/**
|
||||
* The call type of the method
|
||||
*/
|
||||
MethodType methodType();
|
||||
}
|
||||
|
|
@ -33,6 +33,12 @@ public final class SimpleServiceGrpc {
|
|||
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.protobuf.SimpleRequest,
|
||||
io.grpc.testing.protobuf.SimpleResponse> getUnaryRpcMethod;
|
||||
|
||||
@io.grpc.stub.annotations.RpcMethod(
|
||||
fullServiceName = "grpc.testing.SimpleService",
|
||||
methodName = "UnaryRpc",
|
||||
inputType = io.grpc.testing.protobuf.SimpleRequest.class,
|
||||
outputType = io.grpc.testing.protobuf.SimpleResponse.class,
|
||||
methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
|
||||
public static io.grpc.MethodDescriptor<io.grpc.testing.protobuf.SimpleRequest,
|
||||
io.grpc.testing.protobuf.SimpleResponse> getUnaryRpcMethod() {
|
||||
io.grpc.MethodDescriptor<io.grpc.testing.protobuf.SimpleRequest, io.grpc.testing.protobuf.SimpleResponse> getUnaryRpcMethod;
|
||||
|
|
@ -60,6 +66,12 @@ public final class SimpleServiceGrpc {
|
|||
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.protobuf.SimpleRequest,
|
||||
io.grpc.testing.protobuf.SimpleResponse> getClientStreamingRpcMethod;
|
||||
|
||||
@io.grpc.stub.annotations.RpcMethod(
|
||||
fullServiceName = "grpc.testing.SimpleService",
|
||||
methodName = "ClientStreamingRpc",
|
||||
inputType = io.grpc.testing.protobuf.SimpleRequest.class,
|
||||
outputType = io.grpc.testing.protobuf.SimpleResponse.class,
|
||||
methodType = io.grpc.MethodDescriptor.MethodType.CLIENT_STREAMING)
|
||||
public static io.grpc.MethodDescriptor<io.grpc.testing.protobuf.SimpleRequest,
|
||||
io.grpc.testing.protobuf.SimpleResponse> getClientStreamingRpcMethod() {
|
||||
io.grpc.MethodDescriptor<io.grpc.testing.protobuf.SimpleRequest, io.grpc.testing.protobuf.SimpleResponse> getClientStreamingRpcMethod;
|
||||
|
|
@ -87,6 +99,12 @@ public final class SimpleServiceGrpc {
|
|||
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.protobuf.SimpleRequest,
|
||||
io.grpc.testing.protobuf.SimpleResponse> getServerStreamingRpcMethod;
|
||||
|
||||
@io.grpc.stub.annotations.RpcMethod(
|
||||
fullServiceName = "grpc.testing.SimpleService",
|
||||
methodName = "ServerStreamingRpc",
|
||||
inputType = io.grpc.testing.protobuf.SimpleRequest.class,
|
||||
outputType = io.grpc.testing.protobuf.SimpleResponse.class,
|
||||
methodType = io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING)
|
||||
public static io.grpc.MethodDescriptor<io.grpc.testing.protobuf.SimpleRequest,
|
||||
io.grpc.testing.protobuf.SimpleResponse> getServerStreamingRpcMethod() {
|
||||
io.grpc.MethodDescriptor<io.grpc.testing.protobuf.SimpleRequest, io.grpc.testing.protobuf.SimpleResponse> getServerStreamingRpcMethod;
|
||||
|
|
@ -114,6 +132,12 @@ public final class SimpleServiceGrpc {
|
|||
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.protobuf.SimpleRequest,
|
||||
io.grpc.testing.protobuf.SimpleResponse> getBidiStreamingRpcMethod;
|
||||
|
||||
@io.grpc.stub.annotations.RpcMethod(
|
||||
fullServiceName = "grpc.testing.SimpleService",
|
||||
methodName = "BidiStreamingRpc",
|
||||
inputType = io.grpc.testing.protobuf.SimpleRequest.class,
|
||||
outputType = io.grpc.testing.protobuf.SimpleResponse.class,
|
||||
methodType = io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
|
||||
public static io.grpc.MethodDescriptor<io.grpc.testing.protobuf.SimpleRequest,
|
||||
io.grpc.testing.protobuf.SimpleResponse> getBidiStreamingRpcMethod() {
|
||||
io.grpc.MethodDescriptor<io.grpc.testing.protobuf.SimpleRequest, io.grpc.testing.protobuf.SimpleResponse> getBidiStreamingRpcMethod;
|
||||
|
|
|
|||
Loading…
Reference in New Issue