mirror of https://github.com/grpc/grpc-java.git
compiler: move over to method descriptor builder
This commit is contained in:
parent
17b90169d8
commit
4f96b0a483
|
|
@ -30,21 +30,27 @@ public final class BenchmarkServiceGrpc {
|
||||||
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
||||||
public static final io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Messages.SimpleRequest,
|
public static final io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Messages.SimpleRequest,
|
||||||
io.grpc.benchmarks.proto.Messages.SimpleResponse> METHOD_UNARY_CALL =
|
io.grpc.benchmarks.proto.Messages.SimpleResponse> METHOD_UNARY_CALL =
|
||||||
io.grpc.MethodDescriptor.create(
|
io.grpc.MethodDescriptor.<io.grpc.benchmarks.proto.Messages.SimpleRequest, io.grpc.benchmarks.proto.Messages.SimpleResponse>newBuilder()
|
||||||
io.grpc.MethodDescriptor.MethodType.UNARY,
|
.setType(io.grpc.MethodDescriptor.MethodType.UNARY)
|
||||||
generateFullMethodName(
|
.setFullMethodName(generateFullMethodName(
|
||||||
"grpc.testing.BenchmarkService", "UnaryCall"),
|
"grpc.testing.BenchmarkService", "UnaryCall"))
|
||||||
io.grpc.protobuf.ProtoUtils.marshaller(io.grpc.benchmarks.proto.Messages.SimpleRequest.getDefaultInstance()),
|
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
|
||||||
io.grpc.protobuf.ProtoUtils.marshaller(io.grpc.benchmarks.proto.Messages.SimpleResponse.getDefaultInstance()));
|
io.grpc.benchmarks.proto.Messages.SimpleRequest.getDefaultInstance()))
|
||||||
|
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
|
||||||
|
io.grpc.benchmarks.proto.Messages.SimpleResponse.getDefaultInstance()))
|
||||||
|
.build();
|
||||||
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
||||||
public static final io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Messages.SimpleRequest,
|
public static final io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Messages.SimpleRequest,
|
||||||
io.grpc.benchmarks.proto.Messages.SimpleResponse> METHOD_STREAMING_CALL =
|
io.grpc.benchmarks.proto.Messages.SimpleResponse> METHOD_STREAMING_CALL =
|
||||||
io.grpc.MethodDescriptor.create(
|
io.grpc.MethodDescriptor.<io.grpc.benchmarks.proto.Messages.SimpleRequest, io.grpc.benchmarks.proto.Messages.SimpleResponse>newBuilder()
|
||||||
io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING,
|
.setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
|
||||||
generateFullMethodName(
|
.setFullMethodName(generateFullMethodName(
|
||||||
"grpc.testing.BenchmarkService", "StreamingCall"),
|
"grpc.testing.BenchmarkService", "StreamingCall"))
|
||||||
io.grpc.protobuf.ProtoUtils.marshaller(io.grpc.benchmarks.proto.Messages.SimpleRequest.getDefaultInstance()),
|
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
|
||||||
io.grpc.protobuf.ProtoUtils.marshaller(io.grpc.benchmarks.proto.Messages.SimpleResponse.getDefaultInstance()));
|
io.grpc.benchmarks.proto.Messages.SimpleRequest.getDefaultInstance()))
|
||||||
|
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
|
||||||
|
io.grpc.benchmarks.proto.Messages.SimpleResponse.getDefaultInstance()))
|
||||||
|
.build();
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Creates a new async stub that supports all call types for the service
|
* Creates a new async stub that supports all call types for the service
|
||||||
|
|
|
||||||
|
|
@ -30,39 +30,51 @@ public final class WorkerServiceGrpc {
|
||||||
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
||||||
public static final io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Control.ServerArgs,
|
public static final io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Control.ServerArgs,
|
||||||
io.grpc.benchmarks.proto.Control.ServerStatus> METHOD_RUN_SERVER =
|
io.grpc.benchmarks.proto.Control.ServerStatus> METHOD_RUN_SERVER =
|
||||||
io.grpc.MethodDescriptor.create(
|
io.grpc.MethodDescriptor.<io.grpc.benchmarks.proto.Control.ServerArgs, io.grpc.benchmarks.proto.Control.ServerStatus>newBuilder()
|
||||||
io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING,
|
.setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
|
||||||
generateFullMethodName(
|
.setFullMethodName(generateFullMethodName(
|
||||||
"grpc.testing.WorkerService", "RunServer"),
|
"grpc.testing.WorkerService", "RunServer"))
|
||||||
io.grpc.protobuf.ProtoUtils.marshaller(io.grpc.benchmarks.proto.Control.ServerArgs.getDefaultInstance()),
|
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
|
||||||
io.grpc.protobuf.ProtoUtils.marshaller(io.grpc.benchmarks.proto.Control.ServerStatus.getDefaultInstance()));
|
io.grpc.benchmarks.proto.Control.ServerArgs.getDefaultInstance()))
|
||||||
|
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
|
||||||
|
io.grpc.benchmarks.proto.Control.ServerStatus.getDefaultInstance()))
|
||||||
|
.build();
|
||||||
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
||||||
public static final io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Control.ClientArgs,
|
public static final io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Control.ClientArgs,
|
||||||
io.grpc.benchmarks.proto.Control.ClientStatus> METHOD_RUN_CLIENT =
|
io.grpc.benchmarks.proto.Control.ClientStatus> METHOD_RUN_CLIENT =
|
||||||
io.grpc.MethodDescriptor.create(
|
io.grpc.MethodDescriptor.<io.grpc.benchmarks.proto.Control.ClientArgs, io.grpc.benchmarks.proto.Control.ClientStatus>newBuilder()
|
||||||
io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING,
|
.setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
|
||||||
generateFullMethodName(
|
.setFullMethodName(generateFullMethodName(
|
||||||
"grpc.testing.WorkerService", "RunClient"),
|
"grpc.testing.WorkerService", "RunClient"))
|
||||||
io.grpc.protobuf.ProtoUtils.marshaller(io.grpc.benchmarks.proto.Control.ClientArgs.getDefaultInstance()),
|
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
|
||||||
io.grpc.protobuf.ProtoUtils.marshaller(io.grpc.benchmarks.proto.Control.ClientStatus.getDefaultInstance()));
|
io.grpc.benchmarks.proto.Control.ClientArgs.getDefaultInstance()))
|
||||||
|
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
|
||||||
|
io.grpc.benchmarks.proto.Control.ClientStatus.getDefaultInstance()))
|
||||||
|
.build();
|
||||||
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
||||||
public static final io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Control.CoreRequest,
|
public static final io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Control.CoreRequest,
|
||||||
io.grpc.benchmarks.proto.Control.CoreResponse> METHOD_CORE_COUNT =
|
io.grpc.benchmarks.proto.Control.CoreResponse> METHOD_CORE_COUNT =
|
||||||
io.grpc.MethodDescriptor.create(
|
io.grpc.MethodDescriptor.<io.grpc.benchmarks.proto.Control.CoreRequest, io.grpc.benchmarks.proto.Control.CoreResponse>newBuilder()
|
||||||
io.grpc.MethodDescriptor.MethodType.UNARY,
|
.setType(io.grpc.MethodDescriptor.MethodType.UNARY)
|
||||||
generateFullMethodName(
|
.setFullMethodName(generateFullMethodName(
|
||||||
"grpc.testing.WorkerService", "CoreCount"),
|
"grpc.testing.WorkerService", "CoreCount"))
|
||||||
io.grpc.protobuf.ProtoUtils.marshaller(io.grpc.benchmarks.proto.Control.CoreRequest.getDefaultInstance()),
|
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
|
||||||
io.grpc.protobuf.ProtoUtils.marshaller(io.grpc.benchmarks.proto.Control.CoreResponse.getDefaultInstance()));
|
io.grpc.benchmarks.proto.Control.CoreRequest.getDefaultInstance()))
|
||||||
|
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
|
||||||
|
io.grpc.benchmarks.proto.Control.CoreResponse.getDefaultInstance()))
|
||||||
|
.build();
|
||||||
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
||||||
public static final io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Control.Void,
|
public static final io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Control.Void,
|
||||||
io.grpc.benchmarks.proto.Control.Void> METHOD_QUIT_WORKER =
|
io.grpc.benchmarks.proto.Control.Void> METHOD_QUIT_WORKER =
|
||||||
io.grpc.MethodDescriptor.create(
|
io.grpc.MethodDescriptor.<io.grpc.benchmarks.proto.Control.Void, io.grpc.benchmarks.proto.Control.Void>newBuilder()
|
||||||
io.grpc.MethodDescriptor.MethodType.UNARY,
|
.setType(io.grpc.MethodDescriptor.MethodType.UNARY)
|
||||||
generateFullMethodName(
|
.setFullMethodName(generateFullMethodName(
|
||||||
"grpc.testing.WorkerService", "QuitWorker"),
|
"grpc.testing.WorkerService", "QuitWorker"))
|
||||||
io.grpc.protobuf.ProtoUtils.marshaller(io.grpc.benchmarks.proto.Control.Void.getDefaultInstance()),
|
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
|
||||||
io.grpc.protobuf.ProtoUtils.marshaller(io.grpc.benchmarks.proto.Control.Void.getDefaultInstance()));
|
io.grpc.benchmarks.proto.Control.Void.getDefaultInstance()))
|
||||||
|
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
|
||||||
|
io.grpc.benchmarks.proto.Control.Void.getDefaultInstance()))
|
||||||
|
.build();
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Creates a new async stub that supports all call types for the service
|
* Creates a new async stub that supports all call types for the service
|
||||||
|
|
|
||||||
|
|
@ -339,15 +339,15 @@ static void PrintMethodFields(
|
||||||
"@$ExperimentalApi$(\"https://github.com/grpc/grpc-java/issues/1901\")\n"
|
"@$ExperimentalApi$(\"https://github.com/grpc/grpc-java/issues/1901\")\n"
|
||||||
"public static final $MethodDescriptor$<$input_type$,\n"
|
"public static final $MethodDescriptor$<$input_type$,\n"
|
||||||
" $output_type$> $method_field_name$ =\n"
|
" $output_type$> $method_field_name$ =\n"
|
||||||
" $MethodDescriptor$.create(\n"
|
" $MethodDescriptor$.<$input_type$, $output_type$>newBuilder()\n"
|
||||||
" $MethodType$.$method_type$,\n"
|
" .setType($MethodType$.$method_type$)\n"
|
||||||
" generateFullMethodName(\n"
|
" .setFullMethodName(generateFullMethodName(\n"
|
||||||
" \"$Package$$service_name$\", \"$method_name$\"),\n"
|
" \"$Package$$service_name$\", \"$method_name$\"))\n"
|
||||||
" $NanoUtils$.<$input_type$>marshaller(\n"
|
" .setRequestMarshaller($NanoUtils$.<$input_type$>marshaller(\n"
|
||||||
" new NanoFactory<$input_type$>(ARG_IN_$method_field_name$)),\n"
|
" new NanoFactory<$input_type$>(ARG_IN_$method_field_name$)))\n"
|
||||||
" $NanoUtils$.<$output_type$>marshaller(\n"
|
" .setResponseMarshaller($NanoUtils$.<$output_type$>marshaller(\n"
|
||||||
" new NanoFactory<$output_type$>(ARG_OUT_$method_field_name$))\n"
|
" new NanoFactory<$output_type$>(ARG_OUT_$method_field_name$)))\n"
|
||||||
" );\n");
|
" .build();\n");
|
||||||
} else {
|
} else {
|
||||||
if (flavor == ProtoFlavor::LITE) {
|
if (flavor == ProtoFlavor::LITE) {
|
||||||
(*vars)["ProtoUtils"] = "io.grpc.protobuf.lite.ProtoLiteUtils";
|
(*vars)["ProtoUtils"] = "io.grpc.protobuf.lite.ProtoLiteUtils";
|
||||||
|
|
@ -359,12 +359,15 @@ static void PrintMethodFields(
|
||||||
"@$ExperimentalApi$(\"https://github.com/grpc/grpc-java/issues/1901\")\n"
|
"@$ExperimentalApi$(\"https://github.com/grpc/grpc-java/issues/1901\")\n"
|
||||||
"public static final $MethodDescriptor$<$input_type$,\n"
|
"public static final $MethodDescriptor$<$input_type$,\n"
|
||||||
" $output_type$> $method_field_name$ =\n"
|
" $output_type$> $method_field_name$ =\n"
|
||||||
" $MethodDescriptor$.create(\n"
|
" $MethodDescriptor$.<$input_type$, $output_type$>newBuilder()\n"
|
||||||
" $MethodType$.$method_type$,\n"
|
" .setType($MethodType$.$method_type$)\n"
|
||||||
" generateFullMethodName(\n"
|
" .setFullMethodName(generateFullMethodName(\n"
|
||||||
" \"$Package$$service_name$\", \"$method_name$\"),\n"
|
" \"$Package$$service_name$\", \"$method_name$\"))\n"
|
||||||
" $ProtoUtils$.marshaller($input_type$.getDefaultInstance()),\n"
|
" .setRequestMarshaller($ProtoUtils$.marshaller(\n"
|
||||||
" $ProtoUtils$.marshaller($output_type$.getDefaultInstance()));\n");
|
" $input_type$.getDefaultInstance()))\n"
|
||||||
|
" .setResponseMarshaller($ProtoUtils$.marshaller(\n"
|
||||||
|
" $output_type$.getDefaultInstance()))\n"
|
||||||
|
" .build();\n");
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
p->Print("\n");
|
p->Print("\n");
|
||||||
|
|
|
||||||
|
|
@ -33,48 +33,63 @@ public final class TestServiceGrpc {
|
||||||
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
||||||
public static final io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.SimpleRequest,
|
public static final io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.SimpleRequest,
|
||||||
io.grpc.testing.integration.Test.SimpleResponse> METHOD_UNARY_CALL =
|
io.grpc.testing.integration.Test.SimpleResponse> METHOD_UNARY_CALL =
|
||||||
io.grpc.MethodDescriptor.create(
|
io.grpc.MethodDescriptor.<io.grpc.testing.integration.Test.SimpleRequest, io.grpc.testing.integration.Test.SimpleResponse>newBuilder()
|
||||||
io.grpc.MethodDescriptor.MethodType.UNARY,
|
.setType(io.grpc.MethodDescriptor.MethodType.UNARY)
|
||||||
generateFullMethodName(
|
.setFullMethodName(generateFullMethodName(
|
||||||
"grpc.testing.TestService", "UnaryCall"),
|
"grpc.testing.TestService", "UnaryCall"))
|
||||||
io.grpc.protobuf.ProtoUtils.marshaller(io.grpc.testing.integration.Test.SimpleRequest.getDefaultInstance()),
|
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
|
||||||
io.grpc.protobuf.ProtoUtils.marshaller(io.grpc.testing.integration.Test.SimpleResponse.getDefaultInstance()));
|
io.grpc.testing.integration.Test.SimpleRequest.getDefaultInstance()))
|
||||||
|
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
|
||||||
|
io.grpc.testing.integration.Test.SimpleResponse.getDefaultInstance()))
|
||||||
|
.build();
|
||||||
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
||||||
public static final io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.StreamingOutputCallRequest,
|
public static final io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.StreamingOutputCallRequest,
|
||||||
io.grpc.testing.integration.Test.StreamingOutputCallResponse> METHOD_STREAMING_OUTPUT_CALL =
|
io.grpc.testing.integration.Test.StreamingOutputCallResponse> METHOD_STREAMING_OUTPUT_CALL =
|
||||||
io.grpc.MethodDescriptor.create(
|
io.grpc.MethodDescriptor.<io.grpc.testing.integration.Test.StreamingOutputCallRequest, io.grpc.testing.integration.Test.StreamingOutputCallResponse>newBuilder()
|
||||||
io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING,
|
.setType(io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING)
|
||||||
generateFullMethodName(
|
.setFullMethodName(generateFullMethodName(
|
||||||
"grpc.testing.TestService", "StreamingOutputCall"),
|
"grpc.testing.TestService", "StreamingOutputCall"))
|
||||||
io.grpc.protobuf.ProtoUtils.marshaller(io.grpc.testing.integration.Test.StreamingOutputCallRequest.getDefaultInstance()),
|
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
|
||||||
io.grpc.protobuf.ProtoUtils.marshaller(io.grpc.testing.integration.Test.StreamingOutputCallResponse.getDefaultInstance()));
|
io.grpc.testing.integration.Test.StreamingOutputCallRequest.getDefaultInstance()))
|
||||||
|
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
|
||||||
|
io.grpc.testing.integration.Test.StreamingOutputCallResponse.getDefaultInstance()))
|
||||||
|
.build();
|
||||||
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
||||||
public static final io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.StreamingInputCallRequest,
|
public static final io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.StreamingInputCallRequest,
|
||||||
io.grpc.testing.integration.Test.StreamingInputCallResponse> METHOD_STREAMING_INPUT_CALL =
|
io.grpc.testing.integration.Test.StreamingInputCallResponse> METHOD_STREAMING_INPUT_CALL =
|
||||||
io.grpc.MethodDescriptor.create(
|
io.grpc.MethodDescriptor.<io.grpc.testing.integration.Test.StreamingInputCallRequest, io.grpc.testing.integration.Test.StreamingInputCallResponse>newBuilder()
|
||||||
io.grpc.MethodDescriptor.MethodType.CLIENT_STREAMING,
|
.setType(io.grpc.MethodDescriptor.MethodType.CLIENT_STREAMING)
|
||||||
generateFullMethodName(
|
.setFullMethodName(generateFullMethodName(
|
||||||
"grpc.testing.TestService", "StreamingInputCall"),
|
"grpc.testing.TestService", "StreamingInputCall"))
|
||||||
io.grpc.protobuf.ProtoUtils.marshaller(io.grpc.testing.integration.Test.StreamingInputCallRequest.getDefaultInstance()),
|
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
|
||||||
io.grpc.protobuf.ProtoUtils.marshaller(io.grpc.testing.integration.Test.StreamingInputCallResponse.getDefaultInstance()));
|
io.grpc.testing.integration.Test.StreamingInputCallRequest.getDefaultInstance()))
|
||||||
|
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
|
||||||
|
io.grpc.testing.integration.Test.StreamingInputCallResponse.getDefaultInstance()))
|
||||||
|
.build();
|
||||||
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
||||||
public static final io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.StreamingOutputCallRequest,
|
public static final io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.StreamingOutputCallRequest,
|
||||||
io.grpc.testing.integration.Test.StreamingOutputCallResponse> METHOD_FULL_BIDI_CALL =
|
io.grpc.testing.integration.Test.StreamingOutputCallResponse> METHOD_FULL_BIDI_CALL =
|
||||||
io.grpc.MethodDescriptor.create(
|
io.grpc.MethodDescriptor.<io.grpc.testing.integration.Test.StreamingOutputCallRequest, io.grpc.testing.integration.Test.StreamingOutputCallResponse>newBuilder()
|
||||||
io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING,
|
.setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
|
||||||
generateFullMethodName(
|
.setFullMethodName(generateFullMethodName(
|
||||||
"grpc.testing.TestService", "FullBidiCall"),
|
"grpc.testing.TestService", "FullBidiCall"))
|
||||||
io.grpc.protobuf.ProtoUtils.marshaller(io.grpc.testing.integration.Test.StreamingOutputCallRequest.getDefaultInstance()),
|
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
|
||||||
io.grpc.protobuf.ProtoUtils.marshaller(io.grpc.testing.integration.Test.StreamingOutputCallResponse.getDefaultInstance()));
|
io.grpc.testing.integration.Test.StreamingOutputCallRequest.getDefaultInstance()))
|
||||||
|
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
|
||||||
|
io.grpc.testing.integration.Test.StreamingOutputCallResponse.getDefaultInstance()))
|
||||||
|
.build();
|
||||||
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
||||||
public static final io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.StreamingOutputCallRequest,
|
public static final io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.StreamingOutputCallRequest,
|
||||||
io.grpc.testing.integration.Test.StreamingOutputCallResponse> METHOD_HALF_BIDI_CALL =
|
io.grpc.testing.integration.Test.StreamingOutputCallResponse> METHOD_HALF_BIDI_CALL =
|
||||||
io.grpc.MethodDescriptor.create(
|
io.grpc.MethodDescriptor.<io.grpc.testing.integration.Test.StreamingOutputCallRequest, io.grpc.testing.integration.Test.StreamingOutputCallResponse>newBuilder()
|
||||||
io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING,
|
.setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
|
||||||
generateFullMethodName(
|
.setFullMethodName(generateFullMethodName(
|
||||||
"grpc.testing.TestService", "HalfBidiCall"),
|
"grpc.testing.TestService", "HalfBidiCall"))
|
||||||
io.grpc.protobuf.ProtoUtils.marshaller(io.grpc.testing.integration.Test.StreamingOutputCallRequest.getDefaultInstance()),
|
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
|
||||||
io.grpc.protobuf.ProtoUtils.marshaller(io.grpc.testing.integration.Test.StreamingOutputCallResponse.getDefaultInstance()));
|
io.grpc.testing.integration.Test.StreamingOutputCallRequest.getDefaultInstance()))
|
||||||
|
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
|
||||||
|
io.grpc.testing.integration.Test.StreamingOutputCallResponse.getDefaultInstance()))
|
||||||
|
.build();
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Creates a new async stub that supports all call types for the service
|
* Creates a new async stub that supports all call types for the service
|
||||||
|
|
|
||||||
|
|
@ -33,48 +33,63 @@ public final class TestServiceGrpc {
|
||||||
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
||||||
public static final io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.SimpleRequest,
|
public static final io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.SimpleRequest,
|
||||||
io.grpc.testing.integration.Test.SimpleResponse> METHOD_UNARY_CALL =
|
io.grpc.testing.integration.Test.SimpleResponse> METHOD_UNARY_CALL =
|
||||||
io.grpc.MethodDescriptor.create(
|
io.grpc.MethodDescriptor.<io.grpc.testing.integration.Test.SimpleRequest, io.grpc.testing.integration.Test.SimpleResponse>newBuilder()
|
||||||
io.grpc.MethodDescriptor.MethodType.UNARY,
|
.setType(io.grpc.MethodDescriptor.MethodType.UNARY)
|
||||||
generateFullMethodName(
|
.setFullMethodName(generateFullMethodName(
|
||||||
"grpc.testing.TestService", "UnaryCall"),
|
"grpc.testing.TestService", "UnaryCall"))
|
||||||
io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(io.grpc.testing.integration.Test.SimpleRequest.getDefaultInstance()),
|
.setRequestMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(
|
||||||
io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(io.grpc.testing.integration.Test.SimpleResponse.getDefaultInstance()));
|
io.grpc.testing.integration.Test.SimpleRequest.getDefaultInstance()))
|
||||||
|
.setResponseMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(
|
||||||
|
io.grpc.testing.integration.Test.SimpleResponse.getDefaultInstance()))
|
||||||
|
.build();
|
||||||
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
||||||
public static final io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.StreamingOutputCallRequest,
|
public static final io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.StreamingOutputCallRequest,
|
||||||
io.grpc.testing.integration.Test.StreamingOutputCallResponse> METHOD_STREAMING_OUTPUT_CALL =
|
io.grpc.testing.integration.Test.StreamingOutputCallResponse> METHOD_STREAMING_OUTPUT_CALL =
|
||||||
io.grpc.MethodDescriptor.create(
|
io.grpc.MethodDescriptor.<io.grpc.testing.integration.Test.StreamingOutputCallRequest, io.grpc.testing.integration.Test.StreamingOutputCallResponse>newBuilder()
|
||||||
io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING,
|
.setType(io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING)
|
||||||
generateFullMethodName(
|
.setFullMethodName(generateFullMethodName(
|
||||||
"grpc.testing.TestService", "StreamingOutputCall"),
|
"grpc.testing.TestService", "StreamingOutputCall"))
|
||||||
io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(io.grpc.testing.integration.Test.StreamingOutputCallRequest.getDefaultInstance()),
|
.setRequestMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(
|
||||||
io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(io.grpc.testing.integration.Test.StreamingOutputCallResponse.getDefaultInstance()));
|
io.grpc.testing.integration.Test.StreamingOutputCallRequest.getDefaultInstance()))
|
||||||
|
.setResponseMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(
|
||||||
|
io.grpc.testing.integration.Test.StreamingOutputCallResponse.getDefaultInstance()))
|
||||||
|
.build();
|
||||||
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
||||||
public static final io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.StreamingInputCallRequest,
|
public static final io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.StreamingInputCallRequest,
|
||||||
io.grpc.testing.integration.Test.StreamingInputCallResponse> METHOD_STREAMING_INPUT_CALL =
|
io.grpc.testing.integration.Test.StreamingInputCallResponse> METHOD_STREAMING_INPUT_CALL =
|
||||||
io.grpc.MethodDescriptor.create(
|
io.grpc.MethodDescriptor.<io.grpc.testing.integration.Test.StreamingInputCallRequest, io.grpc.testing.integration.Test.StreamingInputCallResponse>newBuilder()
|
||||||
io.grpc.MethodDescriptor.MethodType.CLIENT_STREAMING,
|
.setType(io.grpc.MethodDescriptor.MethodType.CLIENT_STREAMING)
|
||||||
generateFullMethodName(
|
.setFullMethodName(generateFullMethodName(
|
||||||
"grpc.testing.TestService", "StreamingInputCall"),
|
"grpc.testing.TestService", "StreamingInputCall"))
|
||||||
io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(io.grpc.testing.integration.Test.StreamingInputCallRequest.getDefaultInstance()),
|
.setRequestMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(
|
||||||
io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(io.grpc.testing.integration.Test.StreamingInputCallResponse.getDefaultInstance()));
|
io.grpc.testing.integration.Test.StreamingInputCallRequest.getDefaultInstance()))
|
||||||
|
.setResponseMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(
|
||||||
|
io.grpc.testing.integration.Test.StreamingInputCallResponse.getDefaultInstance()))
|
||||||
|
.build();
|
||||||
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
||||||
public static final io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.StreamingOutputCallRequest,
|
public static final io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.StreamingOutputCallRequest,
|
||||||
io.grpc.testing.integration.Test.StreamingOutputCallResponse> METHOD_FULL_BIDI_CALL =
|
io.grpc.testing.integration.Test.StreamingOutputCallResponse> METHOD_FULL_BIDI_CALL =
|
||||||
io.grpc.MethodDescriptor.create(
|
io.grpc.MethodDescriptor.<io.grpc.testing.integration.Test.StreamingOutputCallRequest, io.grpc.testing.integration.Test.StreamingOutputCallResponse>newBuilder()
|
||||||
io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING,
|
.setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
|
||||||
generateFullMethodName(
|
.setFullMethodName(generateFullMethodName(
|
||||||
"grpc.testing.TestService", "FullBidiCall"),
|
"grpc.testing.TestService", "FullBidiCall"))
|
||||||
io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(io.grpc.testing.integration.Test.StreamingOutputCallRequest.getDefaultInstance()),
|
.setRequestMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(
|
||||||
io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(io.grpc.testing.integration.Test.StreamingOutputCallResponse.getDefaultInstance()));
|
io.grpc.testing.integration.Test.StreamingOutputCallRequest.getDefaultInstance()))
|
||||||
|
.setResponseMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(
|
||||||
|
io.grpc.testing.integration.Test.StreamingOutputCallResponse.getDefaultInstance()))
|
||||||
|
.build();
|
||||||
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
||||||
public static final io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.StreamingOutputCallRequest,
|
public static final io.grpc.MethodDescriptor<io.grpc.testing.integration.Test.StreamingOutputCallRequest,
|
||||||
io.grpc.testing.integration.Test.StreamingOutputCallResponse> METHOD_HALF_BIDI_CALL =
|
io.grpc.testing.integration.Test.StreamingOutputCallResponse> METHOD_HALF_BIDI_CALL =
|
||||||
io.grpc.MethodDescriptor.create(
|
io.grpc.MethodDescriptor.<io.grpc.testing.integration.Test.StreamingOutputCallRequest, io.grpc.testing.integration.Test.StreamingOutputCallResponse>newBuilder()
|
||||||
io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING,
|
.setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
|
||||||
generateFullMethodName(
|
.setFullMethodName(generateFullMethodName(
|
||||||
"grpc.testing.TestService", "HalfBidiCall"),
|
"grpc.testing.TestService", "HalfBidiCall"))
|
||||||
io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(io.grpc.testing.integration.Test.StreamingOutputCallRequest.getDefaultInstance()),
|
.setRequestMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(
|
||||||
io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(io.grpc.testing.integration.Test.StreamingOutputCallResponse.getDefaultInstance()));
|
io.grpc.testing.integration.Test.StreamingOutputCallRequest.getDefaultInstance()))
|
||||||
|
.setResponseMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(
|
||||||
|
io.grpc.testing.integration.Test.StreamingOutputCallResponse.getDefaultInstance()))
|
||||||
|
.build();
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Creates a new async stub that supports all call types for the service
|
* Creates a new async stub that supports all call types for the service
|
||||||
|
|
|
||||||
|
|
@ -37,71 +37,71 @@ public final class TestServiceGrpc {
|
||||||
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
||||||
public static final io.grpc.MethodDescriptor<io.grpc.testing.integration.nano.Test.SimpleRequest,
|
public static final io.grpc.MethodDescriptor<io.grpc.testing.integration.nano.Test.SimpleRequest,
|
||||||
io.grpc.testing.integration.nano.Test.SimpleResponse> METHOD_UNARY_CALL =
|
io.grpc.testing.integration.nano.Test.SimpleResponse> METHOD_UNARY_CALL =
|
||||||
io.grpc.MethodDescriptor.create(
|
io.grpc.MethodDescriptor.<io.grpc.testing.integration.nano.Test.SimpleRequest, io.grpc.testing.integration.nano.Test.SimpleResponse>newBuilder()
|
||||||
io.grpc.MethodDescriptor.MethodType.UNARY,
|
.setType(io.grpc.MethodDescriptor.MethodType.UNARY)
|
||||||
generateFullMethodName(
|
.setFullMethodName(generateFullMethodName(
|
||||||
"grpc.testing.TestService", "UnaryCall"),
|
"grpc.testing.TestService", "UnaryCall"))
|
||||||
io.grpc.protobuf.nano.NanoUtils.<io.grpc.testing.integration.nano.Test.SimpleRequest>marshaller(
|
.setRequestMarshaller(io.grpc.protobuf.nano.NanoUtils.<io.grpc.testing.integration.nano.Test.SimpleRequest>marshaller(
|
||||||
new NanoFactory<io.grpc.testing.integration.nano.Test.SimpleRequest>(ARG_IN_METHOD_UNARY_CALL)),
|
new NanoFactory<io.grpc.testing.integration.nano.Test.SimpleRequest>(ARG_IN_METHOD_UNARY_CALL)))
|
||||||
io.grpc.protobuf.nano.NanoUtils.<io.grpc.testing.integration.nano.Test.SimpleResponse>marshaller(
|
.setResponseMarshaller(io.grpc.protobuf.nano.NanoUtils.<io.grpc.testing.integration.nano.Test.SimpleResponse>marshaller(
|
||||||
new NanoFactory<io.grpc.testing.integration.nano.Test.SimpleResponse>(ARG_OUT_METHOD_UNARY_CALL))
|
new NanoFactory<io.grpc.testing.integration.nano.Test.SimpleResponse>(ARG_OUT_METHOD_UNARY_CALL)))
|
||||||
);
|
.build();
|
||||||
private static final int ARG_IN_METHOD_STREAMING_OUTPUT_CALL = 2;
|
private static final int ARG_IN_METHOD_STREAMING_OUTPUT_CALL = 2;
|
||||||
private static final int ARG_OUT_METHOD_STREAMING_OUTPUT_CALL = 3;
|
private static final int ARG_OUT_METHOD_STREAMING_OUTPUT_CALL = 3;
|
||||||
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
||||||
public static final io.grpc.MethodDescriptor<io.grpc.testing.integration.nano.Test.StreamingOutputCallRequest,
|
public static final io.grpc.MethodDescriptor<io.grpc.testing.integration.nano.Test.StreamingOutputCallRequest,
|
||||||
io.grpc.testing.integration.nano.Test.StreamingOutputCallResponse> METHOD_STREAMING_OUTPUT_CALL =
|
io.grpc.testing.integration.nano.Test.StreamingOutputCallResponse> METHOD_STREAMING_OUTPUT_CALL =
|
||||||
io.grpc.MethodDescriptor.create(
|
io.grpc.MethodDescriptor.<io.grpc.testing.integration.nano.Test.StreamingOutputCallRequest, io.grpc.testing.integration.nano.Test.StreamingOutputCallResponse>newBuilder()
|
||||||
io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING,
|
.setType(io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING)
|
||||||
generateFullMethodName(
|
.setFullMethodName(generateFullMethodName(
|
||||||
"grpc.testing.TestService", "StreamingOutputCall"),
|
"grpc.testing.TestService", "StreamingOutputCall"))
|
||||||
io.grpc.protobuf.nano.NanoUtils.<io.grpc.testing.integration.nano.Test.StreamingOutputCallRequest>marshaller(
|
.setRequestMarshaller(io.grpc.protobuf.nano.NanoUtils.<io.grpc.testing.integration.nano.Test.StreamingOutputCallRequest>marshaller(
|
||||||
new NanoFactory<io.grpc.testing.integration.nano.Test.StreamingOutputCallRequest>(ARG_IN_METHOD_STREAMING_OUTPUT_CALL)),
|
new NanoFactory<io.grpc.testing.integration.nano.Test.StreamingOutputCallRequest>(ARG_IN_METHOD_STREAMING_OUTPUT_CALL)))
|
||||||
io.grpc.protobuf.nano.NanoUtils.<io.grpc.testing.integration.nano.Test.StreamingOutputCallResponse>marshaller(
|
.setResponseMarshaller(io.grpc.protobuf.nano.NanoUtils.<io.grpc.testing.integration.nano.Test.StreamingOutputCallResponse>marshaller(
|
||||||
new NanoFactory<io.grpc.testing.integration.nano.Test.StreamingOutputCallResponse>(ARG_OUT_METHOD_STREAMING_OUTPUT_CALL))
|
new NanoFactory<io.grpc.testing.integration.nano.Test.StreamingOutputCallResponse>(ARG_OUT_METHOD_STREAMING_OUTPUT_CALL)))
|
||||||
);
|
.build();
|
||||||
private static final int ARG_IN_METHOD_STREAMING_INPUT_CALL = 4;
|
private static final int ARG_IN_METHOD_STREAMING_INPUT_CALL = 4;
|
||||||
private static final int ARG_OUT_METHOD_STREAMING_INPUT_CALL = 5;
|
private static final int ARG_OUT_METHOD_STREAMING_INPUT_CALL = 5;
|
||||||
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
||||||
public static final io.grpc.MethodDescriptor<io.grpc.testing.integration.nano.Test.StreamingInputCallRequest,
|
public static final io.grpc.MethodDescriptor<io.grpc.testing.integration.nano.Test.StreamingInputCallRequest,
|
||||||
io.grpc.testing.integration.nano.Test.StreamingInputCallResponse> METHOD_STREAMING_INPUT_CALL =
|
io.grpc.testing.integration.nano.Test.StreamingInputCallResponse> METHOD_STREAMING_INPUT_CALL =
|
||||||
io.grpc.MethodDescriptor.create(
|
io.grpc.MethodDescriptor.<io.grpc.testing.integration.nano.Test.StreamingInputCallRequest, io.grpc.testing.integration.nano.Test.StreamingInputCallResponse>newBuilder()
|
||||||
io.grpc.MethodDescriptor.MethodType.CLIENT_STREAMING,
|
.setType(io.grpc.MethodDescriptor.MethodType.CLIENT_STREAMING)
|
||||||
generateFullMethodName(
|
.setFullMethodName(generateFullMethodName(
|
||||||
"grpc.testing.TestService", "StreamingInputCall"),
|
"grpc.testing.TestService", "StreamingInputCall"))
|
||||||
io.grpc.protobuf.nano.NanoUtils.<io.grpc.testing.integration.nano.Test.StreamingInputCallRequest>marshaller(
|
.setRequestMarshaller(io.grpc.protobuf.nano.NanoUtils.<io.grpc.testing.integration.nano.Test.StreamingInputCallRequest>marshaller(
|
||||||
new NanoFactory<io.grpc.testing.integration.nano.Test.StreamingInputCallRequest>(ARG_IN_METHOD_STREAMING_INPUT_CALL)),
|
new NanoFactory<io.grpc.testing.integration.nano.Test.StreamingInputCallRequest>(ARG_IN_METHOD_STREAMING_INPUT_CALL)))
|
||||||
io.grpc.protobuf.nano.NanoUtils.<io.grpc.testing.integration.nano.Test.StreamingInputCallResponse>marshaller(
|
.setResponseMarshaller(io.grpc.protobuf.nano.NanoUtils.<io.grpc.testing.integration.nano.Test.StreamingInputCallResponse>marshaller(
|
||||||
new NanoFactory<io.grpc.testing.integration.nano.Test.StreamingInputCallResponse>(ARG_OUT_METHOD_STREAMING_INPUT_CALL))
|
new NanoFactory<io.grpc.testing.integration.nano.Test.StreamingInputCallResponse>(ARG_OUT_METHOD_STREAMING_INPUT_CALL)))
|
||||||
);
|
.build();
|
||||||
private static final int ARG_IN_METHOD_FULL_BIDI_CALL = 6;
|
private static final int ARG_IN_METHOD_FULL_BIDI_CALL = 6;
|
||||||
private static final int ARG_OUT_METHOD_FULL_BIDI_CALL = 7;
|
private static final int ARG_OUT_METHOD_FULL_BIDI_CALL = 7;
|
||||||
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
||||||
public static final io.grpc.MethodDescriptor<io.grpc.testing.integration.nano.Test.StreamingOutputCallRequest,
|
public static final io.grpc.MethodDescriptor<io.grpc.testing.integration.nano.Test.StreamingOutputCallRequest,
|
||||||
io.grpc.testing.integration.nano.Test.StreamingOutputCallResponse> METHOD_FULL_BIDI_CALL =
|
io.grpc.testing.integration.nano.Test.StreamingOutputCallResponse> METHOD_FULL_BIDI_CALL =
|
||||||
io.grpc.MethodDescriptor.create(
|
io.grpc.MethodDescriptor.<io.grpc.testing.integration.nano.Test.StreamingOutputCallRequest, io.grpc.testing.integration.nano.Test.StreamingOutputCallResponse>newBuilder()
|
||||||
io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING,
|
.setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
|
||||||
generateFullMethodName(
|
.setFullMethodName(generateFullMethodName(
|
||||||
"grpc.testing.TestService", "FullBidiCall"),
|
"grpc.testing.TestService", "FullBidiCall"))
|
||||||
io.grpc.protobuf.nano.NanoUtils.<io.grpc.testing.integration.nano.Test.StreamingOutputCallRequest>marshaller(
|
.setRequestMarshaller(io.grpc.protobuf.nano.NanoUtils.<io.grpc.testing.integration.nano.Test.StreamingOutputCallRequest>marshaller(
|
||||||
new NanoFactory<io.grpc.testing.integration.nano.Test.StreamingOutputCallRequest>(ARG_IN_METHOD_FULL_BIDI_CALL)),
|
new NanoFactory<io.grpc.testing.integration.nano.Test.StreamingOutputCallRequest>(ARG_IN_METHOD_FULL_BIDI_CALL)))
|
||||||
io.grpc.protobuf.nano.NanoUtils.<io.grpc.testing.integration.nano.Test.StreamingOutputCallResponse>marshaller(
|
.setResponseMarshaller(io.grpc.protobuf.nano.NanoUtils.<io.grpc.testing.integration.nano.Test.StreamingOutputCallResponse>marshaller(
|
||||||
new NanoFactory<io.grpc.testing.integration.nano.Test.StreamingOutputCallResponse>(ARG_OUT_METHOD_FULL_BIDI_CALL))
|
new NanoFactory<io.grpc.testing.integration.nano.Test.StreamingOutputCallResponse>(ARG_OUT_METHOD_FULL_BIDI_CALL)))
|
||||||
);
|
.build();
|
||||||
private static final int ARG_IN_METHOD_HALF_BIDI_CALL = 8;
|
private static final int ARG_IN_METHOD_HALF_BIDI_CALL = 8;
|
||||||
private static final int ARG_OUT_METHOD_HALF_BIDI_CALL = 9;
|
private static final int ARG_OUT_METHOD_HALF_BIDI_CALL = 9;
|
||||||
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
||||||
public static final io.grpc.MethodDescriptor<io.grpc.testing.integration.nano.Test.StreamingOutputCallRequest,
|
public static final io.grpc.MethodDescriptor<io.grpc.testing.integration.nano.Test.StreamingOutputCallRequest,
|
||||||
io.grpc.testing.integration.nano.Test.StreamingOutputCallResponse> METHOD_HALF_BIDI_CALL =
|
io.grpc.testing.integration.nano.Test.StreamingOutputCallResponse> METHOD_HALF_BIDI_CALL =
|
||||||
io.grpc.MethodDescriptor.create(
|
io.grpc.MethodDescriptor.<io.grpc.testing.integration.nano.Test.StreamingOutputCallRequest, io.grpc.testing.integration.nano.Test.StreamingOutputCallResponse>newBuilder()
|
||||||
io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING,
|
.setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
|
||||||
generateFullMethodName(
|
.setFullMethodName(generateFullMethodName(
|
||||||
"grpc.testing.TestService", "HalfBidiCall"),
|
"grpc.testing.TestService", "HalfBidiCall"))
|
||||||
io.grpc.protobuf.nano.NanoUtils.<io.grpc.testing.integration.nano.Test.StreamingOutputCallRequest>marshaller(
|
.setRequestMarshaller(io.grpc.protobuf.nano.NanoUtils.<io.grpc.testing.integration.nano.Test.StreamingOutputCallRequest>marshaller(
|
||||||
new NanoFactory<io.grpc.testing.integration.nano.Test.StreamingOutputCallRequest>(ARG_IN_METHOD_HALF_BIDI_CALL)),
|
new NanoFactory<io.grpc.testing.integration.nano.Test.StreamingOutputCallRequest>(ARG_IN_METHOD_HALF_BIDI_CALL)))
|
||||||
io.grpc.protobuf.nano.NanoUtils.<io.grpc.testing.integration.nano.Test.StreamingOutputCallResponse>marshaller(
|
.setResponseMarshaller(io.grpc.protobuf.nano.NanoUtils.<io.grpc.testing.integration.nano.Test.StreamingOutputCallResponse>marshaller(
|
||||||
new NanoFactory<io.grpc.testing.integration.nano.Test.StreamingOutputCallResponse>(ARG_OUT_METHOD_HALF_BIDI_CALL))
|
new NanoFactory<io.grpc.testing.integration.nano.Test.StreamingOutputCallResponse>(ARG_OUT_METHOD_HALF_BIDI_CALL)))
|
||||||
);
|
.build();
|
||||||
|
|
||||||
private static final class NanoFactory<T extends com.google.protobuf.nano.MessageNano>
|
private static final class NanoFactory<T extends com.google.protobuf.nano.MessageNano>
|
||||||
implements io.grpc.protobuf.nano.MessageNanoFactory<T> {
|
implements io.grpc.protobuf.nano.MessageNanoFactory<T> {
|
||||||
|
|
|
||||||
|
|
@ -30,12 +30,15 @@ public final class LoadBalancerGrpc {
|
||||||
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
||||||
public static final io.grpc.MethodDescriptor<io.grpc.grpclb.LoadBalanceRequest,
|
public static final io.grpc.MethodDescriptor<io.grpc.grpclb.LoadBalanceRequest,
|
||||||
io.grpc.grpclb.LoadBalanceResponse> METHOD_BALANCE_LOAD =
|
io.grpc.grpclb.LoadBalanceResponse> METHOD_BALANCE_LOAD =
|
||||||
io.grpc.MethodDescriptor.create(
|
io.grpc.MethodDescriptor.<io.grpc.grpclb.LoadBalanceRequest, io.grpc.grpclb.LoadBalanceResponse>newBuilder()
|
||||||
io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING,
|
.setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
|
||||||
generateFullMethodName(
|
.setFullMethodName(generateFullMethodName(
|
||||||
"grpc.lb.v1.LoadBalancer", "BalanceLoad"),
|
"grpc.lb.v1.LoadBalancer", "BalanceLoad"))
|
||||||
io.grpc.protobuf.ProtoUtils.marshaller(io.grpc.grpclb.LoadBalanceRequest.getDefaultInstance()),
|
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
|
||||||
io.grpc.protobuf.ProtoUtils.marshaller(io.grpc.grpclb.LoadBalanceResponse.getDefaultInstance()));
|
io.grpc.grpclb.LoadBalanceRequest.getDefaultInstance()))
|
||||||
|
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
|
||||||
|
io.grpc.grpclb.LoadBalanceResponse.getDefaultInstance()))
|
||||||
|
.build();
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Creates a new async stub that supports all call types for the service
|
* Creates a new async stub that supports all call types for the service
|
||||||
|
|
|
||||||
|
|
@ -30,12 +30,15 @@ public final class HealthGrpc {
|
||||||
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
||||||
public static final io.grpc.MethodDescriptor<io.grpc.health.v1.HealthCheckRequest,
|
public static final io.grpc.MethodDescriptor<io.grpc.health.v1.HealthCheckRequest,
|
||||||
io.grpc.health.v1.HealthCheckResponse> METHOD_CHECK =
|
io.grpc.health.v1.HealthCheckResponse> METHOD_CHECK =
|
||||||
io.grpc.MethodDescriptor.create(
|
io.grpc.MethodDescriptor.<io.grpc.health.v1.HealthCheckRequest, io.grpc.health.v1.HealthCheckResponse>newBuilder()
|
||||||
io.grpc.MethodDescriptor.MethodType.UNARY,
|
.setType(io.grpc.MethodDescriptor.MethodType.UNARY)
|
||||||
generateFullMethodName(
|
.setFullMethodName(generateFullMethodName(
|
||||||
"grpc.health.v1.Health", "Check"),
|
"grpc.health.v1.Health", "Check"))
|
||||||
io.grpc.protobuf.ProtoUtils.marshaller(io.grpc.health.v1.HealthCheckRequest.getDefaultInstance()),
|
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
|
||||||
io.grpc.protobuf.ProtoUtils.marshaller(io.grpc.health.v1.HealthCheckResponse.getDefaultInstance()));
|
io.grpc.health.v1.HealthCheckRequest.getDefaultInstance()))
|
||||||
|
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
|
||||||
|
io.grpc.health.v1.HealthCheckResponse.getDefaultInstance()))
|
||||||
|
.build();
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Creates a new async stub that supports all call types for the service
|
* Creates a new async stub that supports all call types for the service
|
||||||
|
|
|
||||||
|
|
@ -30,48 +30,63 @@ public final class MonitoringGrpc {
|
||||||
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
||||||
public static final io.grpc.MethodDescriptor<com.google.protobuf.Empty,
|
public static final io.grpc.MethodDescriptor<com.google.protobuf.Empty,
|
||||||
io.grpc.instrumentation.v1alpha.CanonicalRpcStats> METHOD_GET_CANONICAL_RPC_STATS =
|
io.grpc.instrumentation.v1alpha.CanonicalRpcStats> METHOD_GET_CANONICAL_RPC_STATS =
|
||||||
io.grpc.MethodDescriptor.create(
|
io.grpc.MethodDescriptor.<com.google.protobuf.Empty, io.grpc.instrumentation.v1alpha.CanonicalRpcStats>newBuilder()
|
||||||
io.grpc.MethodDescriptor.MethodType.UNARY,
|
.setType(io.grpc.MethodDescriptor.MethodType.UNARY)
|
||||||
generateFullMethodName(
|
.setFullMethodName(generateFullMethodName(
|
||||||
"grpc.instrumentation.v1alpha.Monitoring", "GetCanonicalRpcStats"),
|
"grpc.instrumentation.v1alpha.Monitoring", "GetCanonicalRpcStats"))
|
||||||
io.grpc.protobuf.ProtoUtils.marshaller(com.google.protobuf.Empty.getDefaultInstance()),
|
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
|
||||||
io.grpc.protobuf.ProtoUtils.marshaller(io.grpc.instrumentation.v1alpha.CanonicalRpcStats.getDefaultInstance()));
|
com.google.protobuf.Empty.getDefaultInstance()))
|
||||||
|
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
|
||||||
|
io.grpc.instrumentation.v1alpha.CanonicalRpcStats.getDefaultInstance()))
|
||||||
|
.build();
|
||||||
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
||||||
public static final io.grpc.MethodDescriptor<io.grpc.instrumentation.v1alpha.StatsRequest,
|
public static final io.grpc.MethodDescriptor<io.grpc.instrumentation.v1alpha.StatsRequest,
|
||||||
io.grpc.instrumentation.v1alpha.StatsResponse> METHOD_GET_STATS =
|
io.grpc.instrumentation.v1alpha.StatsResponse> METHOD_GET_STATS =
|
||||||
io.grpc.MethodDescriptor.create(
|
io.grpc.MethodDescriptor.<io.grpc.instrumentation.v1alpha.StatsRequest, io.grpc.instrumentation.v1alpha.StatsResponse>newBuilder()
|
||||||
io.grpc.MethodDescriptor.MethodType.UNARY,
|
.setType(io.grpc.MethodDescriptor.MethodType.UNARY)
|
||||||
generateFullMethodName(
|
.setFullMethodName(generateFullMethodName(
|
||||||
"grpc.instrumentation.v1alpha.Monitoring", "GetStats"),
|
"grpc.instrumentation.v1alpha.Monitoring", "GetStats"))
|
||||||
io.grpc.protobuf.ProtoUtils.marshaller(io.grpc.instrumentation.v1alpha.StatsRequest.getDefaultInstance()),
|
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
|
||||||
io.grpc.protobuf.ProtoUtils.marshaller(io.grpc.instrumentation.v1alpha.StatsResponse.getDefaultInstance()));
|
io.grpc.instrumentation.v1alpha.StatsRequest.getDefaultInstance()))
|
||||||
|
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
|
||||||
|
io.grpc.instrumentation.v1alpha.StatsResponse.getDefaultInstance()))
|
||||||
|
.build();
|
||||||
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
||||||
public static final io.grpc.MethodDescriptor<io.grpc.instrumentation.v1alpha.StatsRequest,
|
public static final io.grpc.MethodDescriptor<io.grpc.instrumentation.v1alpha.StatsRequest,
|
||||||
io.grpc.instrumentation.v1alpha.StatsResponse> METHOD_WATCH_STATS =
|
io.grpc.instrumentation.v1alpha.StatsResponse> METHOD_WATCH_STATS =
|
||||||
io.grpc.MethodDescriptor.create(
|
io.grpc.MethodDescriptor.<io.grpc.instrumentation.v1alpha.StatsRequest, io.grpc.instrumentation.v1alpha.StatsResponse>newBuilder()
|
||||||
io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING,
|
.setType(io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING)
|
||||||
generateFullMethodName(
|
.setFullMethodName(generateFullMethodName(
|
||||||
"grpc.instrumentation.v1alpha.Monitoring", "WatchStats"),
|
"grpc.instrumentation.v1alpha.Monitoring", "WatchStats"))
|
||||||
io.grpc.protobuf.ProtoUtils.marshaller(io.grpc.instrumentation.v1alpha.StatsRequest.getDefaultInstance()),
|
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
|
||||||
io.grpc.protobuf.ProtoUtils.marshaller(io.grpc.instrumentation.v1alpha.StatsResponse.getDefaultInstance()));
|
io.grpc.instrumentation.v1alpha.StatsRequest.getDefaultInstance()))
|
||||||
|
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
|
||||||
|
io.grpc.instrumentation.v1alpha.StatsResponse.getDefaultInstance()))
|
||||||
|
.build();
|
||||||
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
||||||
public static final io.grpc.MethodDescriptor<io.grpc.instrumentation.v1alpha.TraceRequest,
|
public static final io.grpc.MethodDescriptor<io.grpc.instrumentation.v1alpha.TraceRequest,
|
||||||
io.grpc.instrumentation.v1alpha.TraceResponse> METHOD_GET_REQUEST_TRACES =
|
io.grpc.instrumentation.v1alpha.TraceResponse> METHOD_GET_REQUEST_TRACES =
|
||||||
io.grpc.MethodDescriptor.create(
|
io.grpc.MethodDescriptor.<io.grpc.instrumentation.v1alpha.TraceRequest, io.grpc.instrumentation.v1alpha.TraceResponse>newBuilder()
|
||||||
io.grpc.MethodDescriptor.MethodType.UNARY,
|
.setType(io.grpc.MethodDescriptor.MethodType.UNARY)
|
||||||
generateFullMethodName(
|
.setFullMethodName(generateFullMethodName(
|
||||||
"grpc.instrumentation.v1alpha.Monitoring", "GetRequestTraces"),
|
"grpc.instrumentation.v1alpha.Monitoring", "GetRequestTraces"))
|
||||||
io.grpc.protobuf.ProtoUtils.marshaller(io.grpc.instrumentation.v1alpha.TraceRequest.getDefaultInstance()),
|
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
|
||||||
io.grpc.protobuf.ProtoUtils.marshaller(io.grpc.instrumentation.v1alpha.TraceResponse.getDefaultInstance()));
|
io.grpc.instrumentation.v1alpha.TraceRequest.getDefaultInstance()))
|
||||||
|
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
|
||||||
|
io.grpc.instrumentation.v1alpha.TraceResponse.getDefaultInstance()))
|
||||||
|
.build();
|
||||||
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
||||||
public static final io.grpc.MethodDescriptor<io.grpc.instrumentation.v1alpha.MonitoringDataGroup,
|
public static final io.grpc.MethodDescriptor<io.grpc.instrumentation.v1alpha.MonitoringDataGroup,
|
||||||
io.grpc.instrumentation.v1alpha.CustomMonitoringData> METHOD_GET_CUSTOM_MONITORING_DATA =
|
io.grpc.instrumentation.v1alpha.CustomMonitoringData> METHOD_GET_CUSTOM_MONITORING_DATA =
|
||||||
io.grpc.MethodDescriptor.create(
|
io.grpc.MethodDescriptor.<io.grpc.instrumentation.v1alpha.MonitoringDataGroup, io.grpc.instrumentation.v1alpha.CustomMonitoringData>newBuilder()
|
||||||
io.grpc.MethodDescriptor.MethodType.UNARY,
|
.setType(io.grpc.MethodDescriptor.MethodType.UNARY)
|
||||||
generateFullMethodName(
|
.setFullMethodName(generateFullMethodName(
|
||||||
"grpc.instrumentation.v1alpha.Monitoring", "GetCustomMonitoringData"),
|
"grpc.instrumentation.v1alpha.Monitoring", "GetCustomMonitoringData"))
|
||||||
io.grpc.protobuf.ProtoUtils.marshaller(io.grpc.instrumentation.v1alpha.MonitoringDataGroup.getDefaultInstance()),
|
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
|
||||||
io.grpc.protobuf.ProtoUtils.marshaller(io.grpc.instrumentation.v1alpha.CustomMonitoringData.getDefaultInstance()));
|
io.grpc.instrumentation.v1alpha.MonitoringDataGroup.getDefaultInstance()))
|
||||||
|
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
|
||||||
|
io.grpc.instrumentation.v1alpha.CustomMonitoringData.getDefaultInstance()))
|
||||||
|
.build();
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Creates a new async stub that supports all call types for the service
|
* Creates a new async stub that supports all call types for the service
|
||||||
|
|
|
||||||
|
|
@ -30,12 +30,15 @@ public final class ServerReflectionGrpc {
|
||||||
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
||||||
public static final io.grpc.MethodDescriptor<io.grpc.reflection.v1alpha.ServerReflectionRequest,
|
public static final io.grpc.MethodDescriptor<io.grpc.reflection.v1alpha.ServerReflectionRequest,
|
||||||
io.grpc.reflection.v1alpha.ServerReflectionResponse> METHOD_SERVER_REFLECTION_INFO =
|
io.grpc.reflection.v1alpha.ServerReflectionResponse> METHOD_SERVER_REFLECTION_INFO =
|
||||||
io.grpc.MethodDescriptor.create(
|
io.grpc.MethodDescriptor.<io.grpc.reflection.v1alpha.ServerReflectionRequest, io.grpc.reflection.v1alpha.ServerReflectionResponse>newBuilder()
|
||||||
io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING,
|
.setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
|
||||||
generateFullMethodName(
|
.setFullMethodName(generateFullMethodName(
|
||||||
"grpc.reflection.v1alpha.ServerReflection", "ServerReflectionInfo"),
|
"grpc.reflection.v1alpha.ServerReflection", "ServerReflectionInfo"))
|
||||||
io.grpc.protobuf.ProtoUtils.marshaller(io.grpc.reflection.v1alpha.ServerReflectionRequest.getDefaultInstance()),
|
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
|
||||||
io.grpc.protobuf.ProtoUtils.marshaller(io.grpc.reflection.v1alpha.ServerReflectionResponse.getDefaultInstance()));
|
io.grpc.reflection.v1alpha.ServerReflectionRequest.getDefaultInstance()))
|
||||||
|
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
|
||||||
|
io.grpc.reflection.v1alpha.ServerReflectionResponse.getDefaultInstance()))
|
||||||
|
.build();
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Creates a new async stub that supports all call types for the service
|
* Creates a new async stub that supports all call types for the service
|
||||||
|
|
|
||||||
|
|
@ -33,12 +33,15 @@ public final class AnotherDynamicServiceGrpc {
|
||||||
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
||||||
public static final io.grpc.MethodDescriptor<io.grpc.reflection.testing.DynamicRequest,
|
public static final io.grpc.MethodDescriptor<io.grpc.reflection.testing.DynamicRequest,
|
||||||
io.grpc.reflection.testing.DynamicReply> METHOD_METHOD =
|
io.grpc.reflection.testing.DynamicReply> METHOD_METHOD =
|
||||||
io.grpc.MethodDescriptor.create(
|
io.grpc.MethodDescriptor.<io.grpc.reflection.testing.DynamicRequest, io.grpc.reflection.testing.DynamicReply>newBuilder()
|
||||||
io.grpc.MethodDescriptor.MethodType.UNARY,
|
.setType(io.grpc.MethodDescriptor.MethodType.UNARY)
|
||||||
generateFullMethodName(
|
.setFullMethodName(generateFullMethodName(
|
||||||
"grpc.reflection.testing.AnotherDynamicService", "Method"),
|
"grpc.reflection.testing.AnotherDynamicService", "Method"))
|
||||||
io.grpc.protobuf.ProtoUtils.marshaller(io.grpc.reflection.testing.DynamicRequest.getDefaultInstance()),
|
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
|
||||||
io.grpc.protobuf.ProtoUtils.marshaller(io.grpc.reflection.testing.DynamicReply.getDefaultInstance()));
|
io.grpc.reflection.testing.DynamicRequest.getDefaultInstance()))
|
||||||
|
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
|
||||||
|
io.grpc.reflection.testing.DynamicReply.getDefaultInstance()))
|
||||||
|
.build();
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Creates a new async stub that supports all call types for the service
|
* Creates a new async stub that supports all call types for the service
|
||||||
|
|
|
||||||
|
|
@ -33,12 +33,15 @@ public final class DynamicServiceGrpc {
|
||||||
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
||||||
public static final io.grpc.MethodDescriptor<io.grpc.reflection.testing.DynamicRequest,
|
public static final io.grpc.MethodDescriptor<io.grpc.reflection.testing.DynamicRequest,
|
||||||
io.grpc.reflection.testing.DynamicReply> METHOD_METHOD =
|
io.grpc.reflection.testing.DynamicReply> METHOD_METHOD =
|
||||||
io.grpc.MethodDescriptor.create(
|
io.grpc.MethodDescriptor.<io.grpc.reflection.testing.DynamicRequest, io.grpc.reflection.testing.DynamicReply>newBuilder()
|
||||||
io.grpc.MethodDescriptor.MethodType.UNARY,
|
.setType(io.grpc.MethodDescriptor.MethodType.UNARY)
|
||||||
generateFullMethodName(
|
.setFullMethodName(generateFullMethodName(
|
||||||
"grpc.reflection.testing.DynamicService", "Method"),
|
"grpc.reflection.testing.DynamicService", "Method"))
|
||||||
io.grpc.protobuf.ProtoUtils.marshaller(io.grpc.reflection.testing.DynamicRequest.getDefaultInstance()),
|
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
|
||||||
io.grpc.protobuf.ProtoUtils.marshaller(io.grpc.reflection.testing.DynamicReply.getDefaultInstance()));
|
io.grpc.reflection.testing.DynamicRequest.getDefaultInstance()))
|
||||||
|
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
|
||||||
|
io.grpc.reflection.testing.DynamicReply.getDefaultInstance()))
|
||||||
|
.build();
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Creates a new async stub that supports all call types for the service
|
* Creates a new async stub that supports all call types for the service
|
||||||
|
|
|
||||||
|
|
@ -30,12 +30,15 @@ public final class ReflectableServiceGrpc {
|
||||||
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
||||||
public static final io.grpc.MethodDescriptor<io.grpc.reflection.testing.Request,
|
public static final io.grpc.MethodDescriptor<io.grpc.reflection.testing.Request,
|
||||||
io.grpc.reflection.testing.Reply> METHOD_METHOD =
|
io.grpc.reflection.testing.Reply> METHOD_METHOD =
|
||||||
io.grpc.MethodDescriptor.create(
|
io.grpc.MethodDescriptor.<io.grpc.reflection.testing.Request, io.grpc.reflection.testing.Reply>newBuilder()
|
||||||
io.grpc.MethodDescriptor.MethodType.UNARY,
|
.setType(io.grpc.MethodDescriptor.MethodType.UNARY)
|
||||||
generateFullMethodName(
|
.setFullMethodName(generateFullMethodName(
|
||||||
"grpc.reflection.testing.ReflectableService", "Method"),
|
"grpc.reflection.testing.ReflectableService", "Method"))
|
||||||
io.grpc.protobuf.ProtoUtils.marshaller(io.grpc.reflection.testing.Request.getDefaultInstance()),
|
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
|
||||||
io.grpc.protobuf.ProtoUtils.marshaller(io.grpc.reflection.testing.Reply.getDefaultInstance()));
|
io.grpc.reflection.testing.Request.getDefaultInstance()))
|
||||||
|
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
|
||||||
|
io.grpc.reflection.testing.Reply.getDefaultInstance()))
|
||||||
|
.build();
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Creates a new async stub that supports all call types for the service
|
* Creates a new async stub that supports all call types for the service
|
||||||
|
|
|
||||||
|
|
@ -30,21 +30,27 @@ public final class MetricsServiceGrpc {
|
||||||
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
||||||
public static final io.grpc.MethodDescriptor<io.grpc.testing.integration.Metrics.EmptyMessage,
|
public static final io.grpc.MethodDescriptor<io.grpc.testing.integration.Metrics.EmptyMessage,
|
||||||
io.grpc.testing.integration.Metrics.GaugeResponse> METHOD_GET_ALL_GAUGES =
|
io.grpc.testing.integration.Metrics.GaugeResponse> METHOD_GET_ALL_GAUGES =
|
||||||
io.grpc.MethodDescriptor.create(
|
io.grpc.MethodDescriptor.<io.grpc.testing.integration.Metrics.EmptyMessage, io.grpc.testing.integration.Metrics.GaugeResponse>newBuilder()
|
||||||
io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING,
|
.setType(io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING)
|
||||||
generateFullMethodName(
|
.setFullMethodName(generateFullMethodName(
|
||||||
"grpc.testing.MetricsService", "GetAllGauges"),
|
"grpc.testing.MetricsService", "GetAllGauges"))
|
||||||
io.grpc.protobuf.ProtoUtils.marshaller(io.grpc.testing.integration.Metrics.EmptyMessage.getDefaultInstance()),
|
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
|
||||||
io.grpc.protobuf.ProtoUtils.marshaller(io.grpc.testing.integration.Metrics.GaugeResponse.getDefaultInstance()));
|
io.grpc.testing.integration.Metrics.EmptyMessage.getDefaultInstance()))
|
||||||
|
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
|
||||||
|
io.grpc.testing.integration.Metrics.GaugeResponse.getDefaultInstance()))
|
||||||
|
.build();
|
||||||
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
||||||
public static final io.grpc.MethodDescriptor<io.grpc.testing.integration.Metrics.GaugeRequest,
|
public static final io.grpc.MethodDescriptor<io.grpc.testing.integration.Metrics.GaugeRequest,
|
||||||
io.grpc.testing.integration.Metrics.GaugeResponse> METHOD_GET_GAUGE =
|
io.grpc.testing.integration.Metrics.GaugeResponse> METHOD_GET_GAUGE =
|
||||||
io.grpc.MethodDescriptor.create(
|
io.grpc.MethodDescriptor.<io.grpc.testing.integration.Metrics.GaugeRequest, io.grpc.testing.integration.Metrics.GaugeResponse>newBuilder()
|
||||||
io.grpc.MethodDescriptor.MethodType.UNARY,
|
.setType(io.grpc.MethodDescriptor.MethodType.UNARY)
|
||||||
generateFullMethodName(
|
.setFullMethodName(generateFullMethodName(
|
||||||
"grpc.testing.MetricsService", "GetGauge"),
|
"grpc.testing.MetricsService", "GetGauge"))
|
||||||
io.grpc.protobuf.ProtoUtils.marshaller(io.grpc.testing.integration.Metrics.GaugeRequest.getDefaultInstance()),
|
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
|
||||||
io.grpc.protobuf.ProtoUtils.marshaller(io.grpc.testing.integration.Metrics.GaugeResponse.getDefaultInstance()));
|
io.grpc.testing.integration.Metrics.GaugeRequest.getDefaultInstance()))
|
||||||
|
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
|
||||||
|
io.grpc.testing.integration.Metrics.GaugeResponse.getDefaultInstance()))
|
||||||
|
.build();
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Creates a new async stub that supports all call types for the service
|
* Creates a new async stub that supports all call types for the service
|
||||||
|
|
|
||||||
|
|
@ -33,21 +33,27 @@ public final class ReconnectServiceGrpc {
|
||||||
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
||||||
public static final io.grpc.MethodDescriptor<com.google.protobuf.EmptyProtos.Empty,
|
public static final io.grpc.MethodDescriptor<com.google.protobuf.EmptyProtos.Empty,
|
||||||
com.google.protobuf.EmptyProtos.Empty> METHOD_START =
|
com.google.protobuf.EmptyProtos.Empty> METHOD_START =
|
||||||
io.grpc.MethodDescriptor.create(
|
io.grpc.MethodDescriptor.<com.google.protobuf.EmptyProtos.Empty, com.google.protobuf.EmptyProtos.Empty>newBuilder()
|
||||||
io.grpc.MethodDescriptor.MethodType.UNARY,
|
.setType(io.grpc.MethodDescriptor.MethodType.UNARY)
|
||||||
generateFullMethodName(
|
.setFullMethodName(generateFullMethodName(
|
||||||
"grpc.testing.ReconnectService", "Start"),
|
"grpc.testing.ReconnectService", "Start"))
|
||||||
io.grpc.protobuf.ProtoUtils.marshaller(com.google.protobuf.EmptyProtos.Empty.getDefaultInstance()),
|
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
|
||||||
io.grpc.protobuf.ProtoUtils.marshaller(com.google.protobuf.EmptyProtos.Empty.getDefaultInstance()));
|
com.google.protobuf.EmptyProtos.Empty.getDefaultInstance()))
|
||||||
|
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
|
||||||
|
com.google.protobuf.EmptyProtos.Empty.getDefaultInstance()))
|
||||||
|
.build();
|
||||||
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
||||||
public static final io.grpc.MethodDescriptor<com.google.protobuf.EmptyProtos.Empty,
|
public static final io.grpc.MethodDescriptor<com.google.protobuf.EmptyProtos.Empty,
|
||||||
io.grpc.testing.integration.Messages.ReconnectInfo> METHOD_STOP =
|
io.grpc.testing.integration.Messages.ReconnectInfo> METHOD_STOP =
|
||||||
io.grpc.MethodDescriptor.create(
|
io.grpc.MethodDescriptor.<com.google.protobuf.EmptyProtos.Empty, io.grpc.testing.integration.Messages.ReconnectInfo>newBuilder()
|
||||||
io.grpc.MethodDescriptor.MethodType.UNARY,
|
.setType(io.grpc.MethodDescriptor.MethodType.UNARY)
|
||||||
generateFullMethodName(
|
.setFullMethodName(generateFullMethodName(
|
||||||
"grpc.testing.ReconnectService", "Stop"),
|
"grpc.testing.ReconnectService", "Stop"))
|
||||||
io.grpc.protobuf.ProtoUtils.marshaller(com.google.protobuf.EmptyProtos.Empty.getDefaultInstance()),
|
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
|
||||||
io.grpc.protobuf.ProtoUtils.marshaller(io.grpc.testing.integration.Messages.ReconnectInfo.getDefaultInstance()));
|
com.google.protobuf.EmptyProtos.Empty.getDefaultInstance()))
|
||||||
|
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
|
||||||
|
io.grpc.testing.integration.Messages.ReconnectInfo.getDefaultInstance()))
|
||||||
|
.build();
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Creates a new async stub that supports all call types for the service
|
* Creates a new async stub that supports all call types for the service
|
||||||
|
|
|
||||||
|
|
@ -34,66 +34,87 @@ public final class TestServiceGrpc {
|
||||||
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
||||||
public static final io.grpc.MethodDescriptor<com.google.protobuf.EmptyProtos.Empty,
|
public static final io.grpc.MethodDescriptor<com.google.protobuf.EmptyProtos.Empty,
|
||||||
com.google.protobuf.EmptyProtos.Empty> METHOD_EMPTY_CALL =
|
com.google.protobuf.EmptyProtos.Empty> METHOD_EMPTY_CALL =
|
||||||
io.grpc.MethodDescriptor.create(
|
io.grpc.MethodDescriptor.<com.google.protobuf.EmptyProtos.Empty, com.google.protobuf.EmptyProtos.Empty>newBuilder()
|
||||||
io.grpc.MethodDescriptor.MethodType.UNARY,
|
.setType(io.grpc.MethodDescriptor.MethodType.UNARY)
|
||||||
generateFullMethodName(
|
.setFullMethodName(generateFullMethodName(
|
||||||
"grpc.testing.TestService", "EmptyCall"),
|
"grpc.testing.TestService", "EmptyCall"))
|
||||||
io.grpc.protobuf.ProtoUtils.marshaller(com.google.protobuf.EmptyProtos.Empty.getDefaultInstance()),
|
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
|
||||||
io.grpc.protobuf.ProtoUtils.marshaller(com.google.protobuf.EmptyProtos.Empty.getDefaultInstance()));
|
com.google.protobuf.EmptyProtos.Empty.getDefaultInstance()))
|
||||||
|
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
|
||||||
|
com.google.protobuf.EmptyProtos.Empty.getDefaultInstance()))
|
||||||
|
.build();
|
||||||
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
||||||
public static final io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.SimpleRequest,
|
public static final io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.SimpleRequest,
|
||||||
io.grpc.testing.integration.Messages.SimpleResponse> METHOD_UNARY_CALL =
|
io.grpc.testing.integration.Messages.SimpleResponse> METHOD_UNARY_CALL =
|
||||||
io.grpc.MethodDescriptor.create(
|
io.grpc.MethodDescriptor.<io.grpc.testing.integration.Messages.SimpleRequest, io.grpc.testing.integration.Messages.SimpleResponse>newBuilder()
|
||||||
io.grpc.MethodDescriptor.MethodType.UNARY,
|
.setType(io.grpc.MethodDescriptor.MethodType.UNARY)
|
||||||
generateFullMethodName(
|
.setFullMethodName(generateFullMethodName(
|
||||||
"grpc.testing.TestService", "UnaryCall"),
|
"grpc.testing.TestService", "UnaryCall"))
|
||||||
io.grpc.protobuf.ProtoUtils.marshaller(io.grpc.testing.integration.Messages.SimpleRequest.getDefaultInstance()),
|
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
|
||||||
io.grpc.protobuf.ProtoUtils.marshaller(io.grpc.testing.integration.Messages.SimpleResponse.getDefaultInstance()));
|
io.grpc.testing.integration.Messages.SimpleRequest.getDefaultInstance()))
|
||||||
|
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
|
||||||
|
io.grpc.testing.integration.Messages.SimpleResponse.getDefaultInstance()))
|
||||||
|
.build();
|
||||||
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
||||||
public static final io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.StreamingOutputCallRequest,
|
public static final io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.StreamingOutputCallRequest,
|
||||||
io.grpc.testing.integration.Messages.StreamingOutputCallResponse> METHOD_STREAMING_OUTPUT_CALL =
|
io.grpc.testing.integration.Messages.StreamingOutputCallResponse> METHOD_STREAMING_OUTPUT_CALL =
|
||||||
io.grpc.MethodDescriptor.create(
|
io.grpc.MethodDescriptor.<io.grpc.testing.integration.Messages.StreamingOutputCallRequest, io.grpc.testing.integration.Messages.StreamingOutputCallResponse>newBuilder()
|
||||||
io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING,
|
.setType(io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING)
|
||||||
generateFullMethodName(
|
.setFullMethodName(generateFullMethodName(
|
||||||
"grpc.testing.TestService", "StreamingOutputCall"),
|
"grpc.testing.TestService", "StreamingOutputCall"))
|
||||||
io.grpc.protobuf.ProtoUtils.marshaller(io.grpc.testing.integration.Messages.StreamingOutputCallRequest.getDefaultInstance()),
|
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
|
||||||
io.grpc.protobuf.ProtoUtils.marshaller(io.grpc.testing.integration.Messages.StreamingOutputCallResponse.getDefaultInstance()));
|
io.grpc.testing.integration.Messages.StreamingOutputCallRequest.getDefaultInstance()))
|
||||||
|
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
|
||||||
|
io.grpc.testing.integration.Messages.StreamingOutputCallResponse.getDefaultInstance()))
|
||||||
|
.build();
|
||||||
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
||||||
public static final io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.StreamingInputCallRequest,
|
public static final io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.StreamingInputCallRequest,
|
||||||
io.grpc.testing.integration.Messages.StreamingInputCallResponse> METHOD_STREAMING_INPUT_CALL =
|
io.grpc.testing.integration.Messages.StreamingInputCallResponse> METHOD_STREAMING_INPUT_CALL =
|
||||||
io.grpc.MethodDescriptor.create(
|
io.grpc.MethodDescriptor.<io.grpc.testing.integration.Messages.StreamingInputCallRequest, io.grpc.testing.integration.Messages.StreamingInputCallResponse>newBuilder()
|
||||||
io.grpc.MethodDescriptor.MethodType.CLIENT_STREAMING,
|
.setType(io.grpc.MethodDescriptor.MethodType.CLIENT_STREAMING)
|
||||||
generateFullMethodName(
|
.setFullMethodName(generateFullMethodName(
|
||||||
"grpc.testing.TestService", "StreamingInputCall"),
|
"grpc.testing.TestService", "StreamingInputCall"))
|
||||||
io.grpc.protobuf.ProtoUtils.marshaller(io.grpc.testing.integration.Messages.StreamingInputCallRequest.getDefaultInstance()),
|
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
|
||||||
io.grpc.protobuf.ProtoUtils.marshaller(io.grpc.testing.integration.Messages.StreamingInputCallResponse.getDefaultInstance()));
|
io.grpc.testing.integration.Messages.StreamingInputCallRequest.getDefaultInstance()))
|
||||||
|
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
|
||||||
|
io.grpc.testing.integration.Messages.StreamingInputCallResponse.getDefaultInstance()))
|
||||||
|
.build();
|
||||||
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
||||||
public static final io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.StreamingOutputCallRequest,
|
public static final io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.StreamingOutputCallRequest,
|
||||||
io.grpc.testing.integration.Messages.StreamingOutputCallResponse> METHOD_FULL_DUPLEX_CALL =
|
io.grpc.testing.integration.Messages.StreamingOutputCallResponse> METHOD_FULL_DUPLEX_CALL =
|
||||||
io.grpc.MethodDescriptor.create(
|
io.grpc.MethodDescriptor.<io.grpc.testing.integration.Messages.StreamingOutputCallRequest, io.grpc.testing.integration.Messages.StreamingOutputCallResponse>newBuilder()
|
||||||
io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING,
|
.setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
|
||||||
generateFullMethodName(
|
.setFullMethodName(generateFullMethodName(
|
||||||
"grpc.testing.TestService", "FullDuplexCall"),
|
"grpc.testing.TestService", "FullDuplexCall"))
|
||||||
io.grpc.protobuf.ProtoUtils.marshaller(io.grpc.testing.integration.Messages.StreamingOutputCallRequest.getDefaultInstance()),
|
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
|
||||||
io.grpc.protobuf.ProtoUtils.marshaller(io.grpc.testing.integration.Messages.StreamingOutputCallResponse.getDefaultInstance()));
|
io.grpc.testing.integration.Messages.StreamingOutputCallRequest.getDefaultInstance()))
|
||||||
|
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
|
||||||
|
io.grpc.testing.integration.Messages.StreamingOutputCallResponse.getDefaultInstance()))
|
||||||
|
.build();
|
||||||
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
||||||
public static final io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.StreamingOutputCallRequest,
|
public static final io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.StreamingOutputCallRequest,
|
||||||
io.grpc.testing.integration.Messages.StreamingOutputCallResponse> METHOD_HALF_DUPLEX_CALL =
|
io.grpc.testing.integration.Messages.StreamingOutputCallResponse> METHOD_HALF_DUPLEX_CALL =
|
||||||
io.grpc.MethodDescriptor.create(
|
io.grpc.MethodDescriptor.<io.grpc.testing.integration.Messages.StreamingOutputCallRequest, io.grpc.testing.integration.Messages.StreamingOutputCallResponse>newBuilder()
|
||||||
io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING,
|
.setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
|
||||||
generateFullMethodName(
|
.setFullMethodName(generateFullMethodName(
|
||||||
"grpc.testing.TestService", "HalfDuplexCall"),
|
"grpc.testing.TestService", "HalfDuplexCall"))
|
||||||
io.grpc.protobuf.ProtoUtils.marshaller(io.grpc.testing.integration.Messages.StreamingOutputCallRequest.getDefaultInstance()),
|
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
|
||||||
io.grpc.protobuf.ProtoUtils.marshaller(io.grpc.testing.integration.Messages.StreamingOutputCallResponse.getDefaultInstance()));
|
io.grpc.testing.integration.Messages.StreamingOutputCallRequest.getDefaultInstance()))
|
||||||
|
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
|
||||||
|
io.grpc.testing.integration.Messages.StreamingOutputCallResponse.getDefaultInstance()))
|
||||||
|
.build();
|
||||||
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
||||||
public static final io.grpc.MethodDescriptor<com.google.protobuf.EmptyProtos.Empty,
|
public static final io.grpc.MethodDescriptor<com.google.protobuf.EmptyProtos.Empty,
|
||||||
com.google.protobuf.EmptyProtos.Empty> METHOD_UNIMPLEMENTED_CALL =
|
com.google.protobuf.EmptyProtos.Empty> METHOD_UNIMPLEMENTED_CALL =
|
||||||
io.grpc.MethodDescriptor.create(
|
io.grpc.MethodDescriptor.<com.google.protobuf.EmptyProtos.Empty, com.google.protobuf.EmptyProtos.Empty>newBuilder()
|
||||||
io.grpc.MethodDescriptor.MethodType.UNARY,
|
.setType(io.grpc.MethodDescriptor.MethodType.UNARY)
|
||||||
generateFullMethodName(
|
.setFullMethodName(generateFullMethodName(
|
||||||
"grpc.testing.TestService", "UnimplementedCall"),
|
"grpc.testing.TestService", "UnimplementedCall"))
|
||||||
io.grpc.protobuf.ProtoUtils.marshaller(com.google.protobuf.EmptyProtos.Empty.getDefaultInstance()),
|
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
|
||||||
io.grpc.protobuf.ProtoUtils.marshaller(com.google.protobuf.EmptyProtos.Empty.getDefaultInstance()));
|
com.google.protobuf.EmptyProtos.Empty.getDefaultInstance()))
|
||||||
|
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
|
||||||
|
com.google.protobuf.EmptyProtos.Empty.getDefaultInstance()))
|
||||||
|
.build();
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Creates a new async stub that supports all call types for the service
|
* Creates a new async stub that supports all call types for the service
|
||||||
|
|
|
||||||
|
|
@ -34,12 +34,15 @@ public final class UnimplementedServiceGrpc {
|
||||||
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
|
||||||
public static final io.grpc.MethodDescriptor<com.google.protobuf.EmptyProtos.Empty,
|
public static final io.grpc.MethodDescriptor<com.google.protobuf.EmptyProtos.Empty,
|
||||||
com.google.protobuf.EmptyProtos.Empty> METHOD_UNIMPLEMENTED_CALL =
|
com.google.protobuf.EmptyProtos.Empty> METHOD_UNIMPLEMENTED_CALL =
|
||||||
io.grpc.MethodDescriptor.create(
|
io.grpc.MethodDescriptor.<com.google.protobuf.EmptyProtos.Empty, com.google.protobuf.EmptyProtos.Empty>newBuilder()
|
||||||
io.grpc.MethodDescriptor.MethodType.UNARY,
|
.setType(io.grpc.MethodDescriptor.MethodType.UNARY)
|
||||||
generateFullMethodName(
|
.setFullMethodName(generateFullMethodName(
|
||||||
"grpc.testing.UnimplementedService", "UnimplementedCall"),
|
"grpc.testing.UnimplementedService", "UnimplementedCall"))
|
||||||
io.grpc.protobuf.ProtoUtils.marshaller(com.google.protobuf.EmptyProtos.Empty.getDefaultInstance()),
|
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
|
||||||
io.grpc.protobuf.ProtoUtils.marshaller(com.google.protobuf.EmptyProtos.Empty.getDefaultInstance()));
|
com.google.protobuf.EmptyProtos.Empty.getDefaultInstance()))
|
||||||
|
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
|
||||||
|
com.google.protobuf.EmptyProtos.Empty.getDefaultInstance()))
|
||||||
|
.build();
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Creates a new async stub that supports all call types for the service
|
* Creates a new async stub that supports all call types for the service
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue