compiler: Use 'SERVICE_NAME' instead of duplicated '$Package$$service… (#5943)

* compiler: Use 'SERVICE_NAME' instead of duplicated '$Package$$service_name$'

* compiler: Align indentation

* Fix typo

* Add modified golden files and all re-generated code to meet Travis CI and Windows build requirements

See PR #5943

* Polishing
This commit is contained in:
liym 2019-07-25 01:37:13 +08:00 committed by Chengyuan Zhang
parent d7b9438d39
commit 47b11ab7a1
27 changed files with 464 additions and 531 deletions

View File

@ -41,22 +41,21 @@ public final class HandshakerServiceGrpc {
if ((getDoHandshakeMethod = HandshakerServiceGrpc.getDoHandshakeMethod) == null) { if ((getDoHandshakeMethod = HandshakerServiceGrpc.getDoHandshakeMethod) == null) {
synchronized (HandshakerServiceGrpc.class) { synchronized (HandshakerServiceGrpc.class) {
if ((getDoHandshakeMethod = HandshakerServiceGrpc.getDoHandshakeMethod) == null) { if ((getDoHandshakeMethod = HandshakerServiceGrpc.getDoHandshakeMethod) == null) {
HandshakerServiceGrpc.getDoHandshakeMethod = getDoHandshakeMethod = HandshakerServiceGrpc.getDoHandshakeMethod = getDoHandshakeMethod =
io.grpc.MethodDescriptor.<io.grpc.alts.internal.HandshakerReq, io.grpc.alts.internal.HandshakerResp>newBuilder() io.grpc.MethodDescriptor.<io.grpc.alts.internal.HandshakerReq, io.grpc.alts.internal.HandshakerResp>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING) .setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(SERVICE_NAME, "DoHandshake"))
"grpc.gcp.HandshakerService", "DoHandshake"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.alts.internal.HandshakerReq.getDefaultInstance())) io.grpc.alts.internal.HandshakerReq.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.alts.internal.HandshakerResp.getDefaultInstance())) io.grpc.alts.internal.HandshakerResp.getDefaultInstance()))
.setSchemaDescriptor(new HandshakerServiceMethodDescriptorSupplier("DoHandshake")) .setSchemaDescriptor(new HandshakerServiceMethodDescriptorSupplier("DoHandshake"))
.build(); .build();
}
} }
} }
return getDoHandshakeMethod; }
return getDoHandshakeMethod;
} }
/** /**

View File

@ -41,22 +41,21 @@ public final class BenchmarkServiceGrpc {
if ((getUnaryCallMethod = BenchmarkServiceGrpc.getUnaryCallMethod) == null) { if ((getUnaryCallMethod = BenchmarkServiceGrpc.getUnaryCallMethod) == null) {
synchronized (BenchmarkServiceGrpc.class) { synchronized (BenchmarkServiceGrpc.class) {
if ((getUnaryCallMethod = BenchmarkServiceGrpc.getUnaryCallMethod) == null) { if ((getUnaryCallMethod = BenchmarkServiceGrpc.getUnaryCallMethod) == null) {
BenchmarkServiceGrpc.getUnaryCallMethod = getUnaryCallMethod = BenchmarkServiceGrpc.getUnaryCallMethod = getUnaryCallMethod =
io.grpc.MethodDescriptor.<io.grpc.benchmarks.proto.Messages.SimpleRequest, io.grpc.benchmarks.proto.Messages.SimpleResponse>newBuilder() io.grpc.MethodDescriptor.<io.grpc.benchmarks.proto.Messages.SimpleRequest, io.grpc.benchmarks.proto.Messages.SimpleResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.UNARY) .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(SERVICE_NAME, "UnaryCall"))
"grpc.testing.BenchmarkService", "UnaryCall"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.benchmarks.proto.Messages.SimpleRequest.getDefaultInstance())) io.grpc.benchmarks.proto.Messages.SimpleRequest.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.benchmarks.proto.Messages.SimpleResponse.getDefaultInstance())) io.grpc.benchmarks.proto.Messages.SimpleResponse.getDefaultInstance()))
.setSchemaDescriptor(new BenchmarkServiceMethodDescriptorSupplier("UnaryCall")) .setSchemaDescriptor(new BenchmarkServiceMethodDescriptorSupplier("UnaryCall"))
.build(); .build();
}
} }
} }
return getUnaryCallMethod; }
return getUnaryCallMethod;
} }
private static volatile io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Messages.SimpleRequest, private static volatile io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Messages.SimpleRequest,
@ -73,22 +72,21 @@ public final class BenchmarkServiceGrpc {
if ((getStreamingCallMethod = BenchmarkServiceGrpc.getStreamingCallMethod) == null) { if ((getStreamingCallMethod = BenchmarkServiceGrpc.getStreamingCallMethod) == null) {
synchronized (BenchmarkServiceGrpc.class) { synchronized (BenchmarkServiceGrpc.class) {
if ((getStreamingCallMethod = BenchmarkServiceGrpc.getStreamingCallMethod) == null) { if ((getStreamingCallMethod = BenchmarkServiceGrpc.getStreamingCallMethod) == null) {
BenchmarkServiceGrpc.getStreamingCallMethod = getStreamingCallMethod = BenchmarkServiceGrpc.getStreamingCallMethod = getStreamingCallMethod =
io.grpc.MethodDescriptor.<io.grpc.benchmarks.proto.Messages.SimpleRequest, io.grpc.benchmarks.proto.Messages.SimpleResponse>newBuilder() io.grpc.MethodDescriptor.<io.grpc.benchmarks.proto.Messages.SimpleRequest, io.grpc.benchmarks.proto.Messages.SimpleResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING) .setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(SERVICE_NAME, "StreamingCall"))
"grpc.testing.BenchmarkService", "StreamingCall"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.benchmarks.proto.Messages.SimpleRequest.getDefaultInstance())) io.grpc.benchmarks.proto.Messages.SimpleRequest.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.benchmarks.proto.Messages.SimpleResponse.getDefaultInstance())) io.grpc.benchmarks.proto.Messages.SimpleResponse.getDefaultInstance()))
.setSchemaDescriptor(new BenchmarkServiceMethodDescriptorSupplier("StreamingCall")) .setSchemaDescriptor(new BenchmarkServiceMethodDescriptorSupplier("StreamingCall"))
.build(); .build();
}
} }
} }
return getStreamingCallMethod; }
return getStreamingCallMethod;
} }
private static volatile io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Messages.SimpleRequest, private static volatile io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Messages.SimpleRequest,
@ -105,22 +103,21 @@ public final class BenchmarkServiceGrpc {
if ((getStreamingFromClientMethod = BenchmarkServiceGrpc.getStreamingFromClientMethod) == null) { if ((getStreamingFromClientMethod = BenchmarkServiceGrpc.getStreamingFromClientMethod) == null) {
synchronized (BenchmarkServiceGrpc.class) { synchronized (BenchmarkServiceGrpc.class) {
if ((getStreamingFromClientMethod = BenchmarkServiceGrpc.getStreamingFromClientMethod) == null) { if ((getStreamingFromClientMethod = BenchmarkServiceGrpc.getStreamingFromClientMethod) == null) {
BenchmarkServiceGrpc.getStreamingFromClientMethod = getStreamingFromClientMethod = BenchmarkServiceGrpc.getStreamingFromClientMethod = getStreamingFromClientMethod =
io.grpc.MethodDescriptor.<io.grpc.benchmarks.proto.Messages.SimpleRequest, io.grpc.benchmarks.proto.Messages.SimpleResponse>newBuilder() io.grpc.MethodDescriptor.<io.grpc.benchmarks.proto.Messages.SimpleRequest, io.grpc.benchmarks.proto.Messages.SimpleResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.CLIENT_STREAMING) .setType(io.grpc.MethodDescriptor.MethodType.CLIENT_STREAMING)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(SERVICE_NAME, "StreamingFromClient"))
"grpc.testing.BenchmarkService", "StreamingFromClient"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.benchmarks.proto.Messages.SimpleRequest.getDefaultInstance())) io.grpc.benchmarks.proto.Messages.SimpleRequest.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.benchmarks.proto.Messages.SimpleResponse.getDefaultInstance())) io.grpc.benchmarks.proto.Messages.SimpleResponse.getDefaultInstance()))
.setSchemaDescriptor(new BenchmarkServiceMethodDescriptorSupplier("StreamingFromClient")) .setSchemaDescriptor(new BenchmarkServiceMethodDescriptorSupplier("StreamingFromClient"))
.build(); .build();
}
} }
} }
return getStreamingFromClientMethod; }
return getStreamingFromClientMethod;
} }
private static volatile io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Messages.SimpleRequest, private static volatile io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Messages.SimpleRequest,
@ -137,22 +134,21 @@ public final class BenchmarkServiceGrpc {
if ((getStreamingFromServerMethod = BenchmarkServiceGrpc.getStreamingFromServerMethod) == null) { if ((getStreamingFromServerMethod = BenchmarkServiceGrpc.getStreamingFromServerMethod) == null) {
synchronized (BenchmarkServiceGrpc.class) { synchronized (BenchmarkServiceGrpc.class) {
if ((getStreamingFromServerMethod = BenchmarkServiceGrpc.getStreamingFromServerMethod) == null) { if ((getStreamingFromServerMethod = BenchmarkServiceGrpc.getStreamingFromServerMethod) == null) {
BenchmarkServiceGrpc.getStreamingFromServerMethod = getStreamingFromServerMethod = BenchmarkServiceGrpc.getStreamingFromServerMethod = getStreamingFromServerMethod =
io.grpc.MethodDescriptor.<io.grpc.benchmarks.proto.Messages.SimpleRequest, io.grpc.benchmarks.proto.Messages.SimpleResponse>newBuilder() io.grpc.MethodDescriptor.<io.grpc.benchmarks.proto.Messages.SimpleRequest, io.grpc.benchmarks.proto.Messages.SimpleResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING) .setType(io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(SERVICE_NAME, "StreamingFromServer"))
"grpc.testing.BenchmarkService", "StreamingFromServer"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.benchmarks.proto.Messages.SimpleRequest.getDefaultInstance())) io.grpc.benchmarks.proto.Messages.SimpleRequest.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.benchmarks.proto.Messages.SimpleResponse.getDefaultInstance())) io.grpc.benchmarks.proto.Messages.SimpleResponse.getDefaultInstance()))
.setSchemaDescriptor(new BenchmarkServiceMethodDescriptorSupplier("StreamingFromServer")) .setSchemaDescriptor(new BenchmarkServiceMethodDescriptorSupplier("StreamingFromServer"))
.build(); .build();
}
} }
} }
return getStreamingFromServerMethod; }
return getStreamingFromServerMethod;
} }
private static volatile io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Messages.SimpleRequest, private static volatile io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Messages.SimpleRequest,
@ -169,22 +165,21 @@ public final class BenchmarkServiceGrpc {
if ((getStreamingBothWaysMethod = BenchmarkServiceGrpc.getStreamingBothWaysMethod) == null) { if ((getStreamingBothWaysMethod = BenchmarkServiceGrpc.getStreamingBothWaysMethod) == null) {
synchronized (BenchmarkServiceGrpc.class) { synchronized (BenchmarkServiceGrpc.class) {
if ((getStreamingBothWaysMethod = BenchmarkServiceGrpc.getStreamingBothWaysMethod) == null) { if ((getStreamingBothWaysMethod = BenchmarkServiceGrpc.getStreamingBothWaysMethod) == null) {
BenchmarkServiceGrpc.getStreamingBothWaysMethod = getStreamingBothWaysMethod = BenchmarkServiceGrpc.getStreamingBothWaysMethod = getStreamingBothWaysMethod =
io.grpc.MethodDescriptor.<io.grpc.benchmarks.proto.Messages.SimpleRequest, io.grpc.benchmarks.proto.Messages.SimpleResponse>newBuilder() io.grpc.MethodDescriptor.<io.grpc.benchmarks.proto.Messages.SimpleRequest, io.grpc.benchmarks.proto.Messages.SimpleResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING) .setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(SERVICE_NAME, "StreamingBothWays"))
"grpc.testing.BenchmarkService", "StreamingBothWays"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.benchmarks.proto.Messages.SimpleRequest.getDefaultInstance())) io.grpc.benchmarks.proto.Messages.SimpleRequest.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.benchmarks.proto.Messages.SimpleResponse.getDefaultInstance())) io.grpc.benchmarks.proto.Messages.SimpleResponse.getDefaultInstance()))
.setSchemaDescriptor(new BenchmarkServiceMethodDescriptorSupplier("StreamingBothWays")) .setSchemaDescriptor(new BenchmarkServiceMethodDescriptorSupplier("StreamingBothWays"))
.build(); .build();
}
} }
} }
return getStreamingBothWaysMethod; }
return getStreamingBothWaysMethod;
} }
/** /**

View File

@ -41,22 +41,21 @@ public final class ReportQpsScenarioServiceGrpc {
if ((getReportScenarioMethod = ReportQpsScenarioServiceGrpc.getReportScenarioMethod) == null) { if ((getReportScenarioMethod = ReportQpsScenarioServiceGrpc.getReportScenarioMethod) == null) {
synchronized (ReportQpsScenarioServiceGrpc.class) { synchronized (ReportQpsScenarioServiceGrpc.class) {
if ((getReportScenarioMethod = ReportQpsScenarioServiceGrpc.getReportScenarioMethod) == null) { if ((getReportScenarioMethod = ReportQpsScenarioServiceGrpc.getReportScenarioMethod) == null) {
ReportQpsScenarioServiceGrpc.getReportScenarioMethod = getReportScenarioMethod = ReportQpsScenarioServiceGrpc.getReportScenarioMethod = getReportScenarioMethod =
io.grpc.MethodDescriptor.<io.grpc.benchmarks.proto.Control.ScenarioResult, io.grpc.benchmarks.proto.Control.Void>newBuilder() io.grpc.MethodDescriptor.<io.grpc.benchmarks.proto.Control.ScenarioResult, io.grpc.benchmarks.proto.Control.Void>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.UNARY) .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(SERVICE_NAME, "ReportScenario"))
"grpc.testing.ReportQpsScenarioService", "ReportScenario"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.benchmarks.proto.Control.ScenarioResult.getDefaultInstance())) io.grpc.benchmarks.proto.Control.ScenarioResult.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.benchmarks.proto.Control.Void.getDefaultInstance())) io.grpc.benchmarks.proto.Control.Void.getDefaultInstance()))
.setSchemaDescriptor(new ReportQpsScenarioServiceMethodDescriptorSupplier("ReportScenario")) .setSchemaDescriptor(new ReportQpsScenarioServiceMethodDescriptorSupplier("ReportScenario"))
.build(); .build();
}
} }
} }
return getReportScenarioMethod; }
return getReportScenarioMethod;
} }
/** /**

View File

@ -41,22 +41,21 @@ public final class WorkerServiceGrpc {
if ((getRunServerMethod = WorkerServiceGrpc.getRunServerMethod) == null) { if ((getRunServerMethod = WorkerServiceGrpc.getRunServerMethod) == null) {
synchronized (WorkerServiceGrpc.class) { synchronized (WorkerServiceGrpc.class) {
if ((getRunServerMethod = WorkerServiceGrpc.getRunServerMethod) == null) { if ((getRunServerMethod = WorkerServiceGrpc.getRunServerMethod) == null) {
WorkerServiceGrpc.getRunServerMethod = getRunServerMethod = WorkerServiceGrpc.getRunServerMethod = getRunServerMethod =
io.grpc.MethodDescriptor.<io.grpc.benchmarks.proto.Control.ServerArgs, io.grpc.benchmarks.proto.Control.ServerStatus>newBuilder() io.grpc.MethodDescriptor.<io.grpc.benchmarks.proto.Control.ServerArgs, io.grpc.benchmarks.proto.Control.ServerStatus>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING) .setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(SERVICE_NAME, "RunServer"))
"grpc.testing.WorkerService", "RunServer"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.benchmarks.proto.Control.ServerArgs.getDefaultInstance())) io.grpc.benchmarks.proto.Control.ServerArgs.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.benchmarks.proto.Control.ServerStatus.getDefaultInstance())) io.grpc.benchmarks.proto.Control.ServerStatus.getDefaultInstance()))
.setSchemaDescriptor(new WorkerServiceMethodDescriptorSupplier("RunServer")) .setSchemaDescriptor(new WorkerServiceMethodDescriptorSupplier("RunServer"))
.build(); .build();
}
} }
} }
return getRunServerMethod; }
return getRunServerMethod;
} }
private static volatile io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Control.ClientArgs, private static volatile io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Control.ClientArgs,
@ -73,22 +72,21 @@ public final class WorkerServiceGrpc {
if ((getRunClientMethod = WorkerServiceGrpc.getRunClientMethod) == null) { if ((getRunClientMethod = WorkerServiceGrpc.getRunClientMethod) == null) {
synchronized (WorkerServiceGrpc.class) { synchronized (WorkerServiceGrpc.class) {
if ((getRunClientMethod = WorkerServiceGrpc.getRunClientMethod) == null) { if ((getRunClientMethod = WorkerServiceGrpc.getRunClientMethod) == null) {
WorkerServiceGrpc.getRunClientMethod = getRunClientMethod = WorkerServiceGrpc.getRunClientMethod = getRunClientMethod =
io.grpc.MethodDescriptor.<io.grpc.benchmarks.proto.Control.ClientArgs, io.grpc.benchmarks.proto.Control.ClientStatus>newBuilder() io.grpc.MethodDescriptor.<io.grpc.benchmarks.proto.Control.ClientArgs, io.grpc.benchmarks.proto.Control.ClientStatus>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING) .setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(SERVICE_NAME, "RunClient"))
"grpc.testing.WorkerService", "RunClient"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.benchmarks.proto.Control.ClientArgs.getDefaultInstance())) io.grpc.benchmarks.proto.Control.ClientArgs.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.benchmarks.proto.Control.ClientStatus.getDefaultInstance())) io.grpc.benchmarks.proto.Control.ClientStatus.getDefaultInstance()))
.setSchemaDescriptor(new WorkerServiceMethodDescriptorSupplier("RunClient")) .setSchemaDescriptor(new WorkerServiceMethodDescriptorSupplier("RunClient"))
.build(); .build();
}
} }
} }
return getRunClientMethod; }
return getRunClientMethod;
} }
private static volatile io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Control.CoreRequest, private static volatile io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Control.CoreRequest,
@ -105,22 +103,21 @@ public final class WorkerServiceGrpc {
if ((getCoreCountMethod = WorkerServiceGrpc.getCoreCountMethod) == null) { if ((getCoreCountMethod = WorkerServiceGrpc.getCoreCountMethod) == null) {
synchronized (WorkerServiceGrpc.class) { synchronized (WorkerServiceGrpc.class) {
if ((getCoreCountMethod = WorkerServiceGrpc.getCoreCountMethod) == null) { if ((getCoreCountMethod = WorkerServiceGrpc.getCoreCountMethod) == null) {
WorkerServiceGrpc.getCoreCountMethod = getCoreCountMethod = WorkerServiceGrpc.getCoreCountMethod = getCoreCountMethod =
io.grpc.MethodDescriptor.<io.grpc.benchmarks.proto.Control.CoreRequest, io.grpc.benchmarks.proto.Control.CoreResponse>newBuilder() io.grpc.MethodDescriptor.<io.grpc.benchmarks.proto.Control.CoreRequest, io.grpc.benchmarks.proto.Control.CoreResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.UNARY) .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(SERVICE_NAME, "CoreCount"))
"grpc.testing.WorkerService", "CoreCount"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.benchmarks.proto.Control.CoreRequest.getDefaultInstance())) io.grpc.benchmarks.proto.Control.CoreRequest.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.benchmarks.proto.Control.CoreResponse.getDefaultInstance())) io.grpc.benchmarks.proto.Control.CoreResponse.getDefaultInstance()))
.setSchemaDescriptor(new WorkerServiceMethodDescriptorSupplier("CoreCount")) .setSchemaDescriptor(new WorkerServiceMethodDescriptorSupplier("CoreCount"))
.build(); .build();
}
} }
} }
return getCoreCountMethod; }
return getCoreCountMethod;
} }
private static volatile io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Control.Void, private static volatile io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Control.Void,
@ -137,22 +134,21 @@ public final class WorkerServiceGrpc {
if ((getQuitWorkerMethod = WorkerServiceGrpc.getQuitWorkerMethod) == null) { if ((getQuitWorkerMethod = WorkerServiceGrpc.getQuitWorkerMethod) == null) {
synchronized (WorkerServiceGrpc.class) { synchronized (WorkerServiceGrpc.class) {
if ((getQuitWorkerMethod = WorkerServiceGrpc.getQuitWorkerMethod) == null) { if ((getQuitWorkerMethod = WorkerServiceGrpc.getQuitWorkerMethod) == null) {
WorkerServiceGrpc.getQuitWorkerMethod = getQuitWorkerMethod = WorkerServiceGrpc.getQuitWorkerMethod = getQuitWorkerMethod =
io.grpc.MethodDescriptor.<io.grpc.benchmarks.proto.Control.Void, io.grpc.benchmarks.proto.Control.Void>newBuilder() io.grpc.MethodDescriptor.<io.grpc.benchmarks.proto.Control.Void, io.grpc.benchmarks.proto.Control.Void>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.UNARY) .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(SERVICE_NAME, "QuitWorker"))
"grpc.testing.WorkerService", "QuitWorker"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setRequestMarshaller(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( .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.benchmarks.proto.Control.Void.getDefaultInstance())) io.grpc.benchmarks.proto.Control.Void.getDefaultInstance()))
.setSchemaDescriptor(new WorkerServiceMethodDescriptorSupplier("QuitWorker")) .setSchemaDescriptor(new WorkerServiceMethodDescriptorSupplier("QuitWorker"))
.build(); .build();
}
} }
} }
return getQuitWorkerMethod; }
return getQuitWorkerMethod;
} }
/** /**

View File

@ -46,11 +46,11 @@ $ protoc --plugin=protoc-gen-grpc-java=build/exe/java_plugin/protoc-gen-grpc-jav
## Installing the codegen to Maven local repository ## Installing the codegen to Maven local repository
This will compile a codegen and put it under your ``~/.m2/repository``. This This will compile a codegen and put it under your ``~/.m2/repository``. This
will make it available to any build tool that pulls codegens from Maven will make it available to any build tool that pulls codegens from Maven
repostiories. repositories.
``` ```
$ ../gradlew publishToMavenLocal $ ../gradlew publishToMavenLocal
``` ```
## Creating a release of GRPC Java ## Creating a release of gRPC Java
Please follow the instructions in ``RELEASING.md`` under the root directory for Please follow the instructions in ``RELEASING.md`` under the root directory for
details on how to create a new release. details on how to create a new release.

View File

@ -407,11 +407,10 @@ static void PrintMethodFields(
" if (($method_new_field_name$ = $service_class_name$.$method_new_field_name$) == null) {\n" " if (($method_new_field_name$ = $service_class_name$.$method_new_field_name$) == null) {\n"
" synchronized ($service_class_name$.class) {\n" " synchronized ($service_class_name$.class) {\n"
" if (($method_new_field_name$ = $service_class_name$.$method_new_field_name$) == null) {\n" " if (($method_new_field_name$ = $service_class_name$.$method_new_field_name$) == null) {\n"
" $service_class_name$.$method_new_field_name$ = $method_new_field_name$ = \n" " $service_class_name$.$method_new_field_name$ = $method_new_field_name$ =\n"
" $MethodDescriptor$.<$input_type$, $output_type$>newBuilder()\n" " $MethodDescriptor$.<$input_type$, $output_type$>newBuilder()\n"
" .setType($MethodType$.$method_type$)\n" " .setType($MethodType$.$method_type$)\n"
" .setFullMethodName(generateFullMethodName(\n" " .setFullMethodName(generateFullMethodName(SERVICE_NAME, \"$method_name$\"))\n"
" \"$Package$$service_name$\", \"$method_name$\"))\n"
" .setSampledToLocalTracing(true)\n" " .setSampledToLocalTracing(true)\n"
" .setRequestMarshaller($ProtoUtils$.marshaller(\n" " .setRequestMarshaller($ProtoUtils$.marshaller(\n"
" $input_type$.getDefaultInstance()))\n" " $input_type$.getDefaultInstance()))\n"
@ -422,17 +421,17 @@ static void PrintMethodFields(
if (flavor == ProtoFlavor::NORMAL) { if (flavor == ProtoFlavor::NORMAL) {
p->Print( p->Print(
*vars, *vars,
" .setSchemaDescriptor(new $proto_method_descriptor_supplier$(\"$method_name$\"))\n"); " .setSchemaDescriptor(new $proto_method_descriptor_supplier$(\"$method_name$\"))\n");
} }
p->Print( p->Print(
*vars, *vars,
" .build();\n"); " .build();\n");
p->Print(*vars, p->Print(*vars,
" }\n"
" }\n" " }\n"
" }\n" " }\n"
" return $method_new_field_name$;\n" " }\n"
" return $method_new_field_name$;\n"
"}\n" "}\n"
"\n"); "\n");
} }

View File

@ -45,22 +45,21 @@ public final class TestDeprecatedServiceGrpc {
if ((getDeprecatedMethodMethod = TestDeprecatedServiceGrpc.getDeprecatedMethodMethod) == null) { if ((getDeprecatedMethodMethod = TestDeprecatedServiceGrpc.getDeprecatedMethodMethod) == null) {
synchronized (TestDeprecatedServiceGrpc.class) { synchronized (TestDeprecatedServiceGrpc.class) {
if ((getDeprecatedMethodMethod = TestDeprecatedServiceGrpc.getDeprecatedMethodMethod) == null) { if ((getDeprecatedMethodMethod = TestDeprecatedServiceGrpc.getDeprecatedMethodMethod) == null) {
TestDeprecatedServiceGrpc.getDeprecatedMethodMethod = getDeprecatedMethodMethod = TestDeprecatedServiceGrpc.getDeprecatedMethodMethod = getDeprecatedMethodMethod =
io.grpc.MethodDescriptor.<io.grpc.testing.compiler.Test.SimpleRequest, io.grpc.testing.compiler.Test.SimpleResponse>newBuilder() io.grpc.MethodDescriptor.<io.grpc.testing.compiler.Test.SimpleRequest, io.grpc.testing.compiler.Test.SimpleResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.UNARY) .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(SERVICE_NAME, "DeprecatedMethod"))
"grpc.testing.compiler.TestDeprecatedService", "DeprecatedMethod"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.testing.compiler.Test.SimpleRequest.getDefaultInstance())) io.grpc.testing.compiler.Test.SimpleRequest.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.testing.compiler.Test.SimpleResponse.getDefaultInstance())) io.grpc.testing.compiler.Test.SimpleResponse.getDefaultInstance()))
.setSchemaDescriptor(new TestDeprecatedServiceMethodDescriptorSupplier("DeprecatedMethod")) .setSchemaDescriptor(new TestDeprecatedServiceMethodDescriptorSupplier("DeprecatedMethod"))
.build(); .build();
}
} }
} }
return getDeprecatedMethodMethod; }
return getDeprecatedMethodMethod;
} }
/** /**

View File

@ -44,22 +44,21 @@ public final class TestServiceGrpc {
if ((getUnaryCallMethod = TestServiceGrpc.getUnaryCallMethod) == null) { if ((getUnaryCallMethod = TestServiceGrpc.getUnaryCallMethod) == null) {
synchronized (TestServiceGrpc.class) { synchronized (TestServiceGrpc.class) {
if ((getUnaryCallMethod = TestServiceGrpc.getUnaryCallMethod) == null) { if ((getUnaryCallMethod = TestServiceGrpc.getUnaryCallMethod) == null) {
TestServiceGrpc.getUnaryCallMethod = getUnaryCallMethod = TestServiceGrpc.getUnaryCallMethod = getUnaryCallMethod =
io.grpc.MethodDescriptor.<io.grpc.testing.compiler.Test.SimpleRequest, io.grpc.testing.compiler.Test.SimpleResponse>newBuilder() io.grpc.MethodDescriptor.<io.grpc.testing.compiler.Test.SimpleRequest, io.grpc.testing.compiler.Test.SimpleResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.UNARY) .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(SERVICE_NAME, "UnaryCall"))
"grpc.testing.compiler.TestService", "UnaryCall"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.testing.compiler.Test.SimpleRequest.getDefaultInstance())) io.grpc.testing.compiler.Test.SimpleRequest.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.testing.compiler.Test.SimpleResponse.getDefaultInstance())) io.grpc.testing.compiler.Test.SimpleResponse.getDefaultInstance()))
.setSchemaDescriptor(new TestServiceMethodDescriptorSupplier("UnaryCall")) .setSchemaDescriptor(new TestServiceMethodDescriptorSupplier("UnaryCall"))
.build(); .build();
}
} }
} }
return getUnaryCallMethod; }
return getUnaryCallMethod;
} }
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest, private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
@ -76,22 +75,21 @@ public final class TestServiceGrpc {
if ((getStreamingOutputCallMethod = TestServiceGrpc.getStreamingOutputCallMethod) == null) { if ((getStreamingOutputCallMethod = TestServiceGrpc.getStreamingOutputCallMethod) == null) {
synchronized (TestServiceGrpc.class) { synchronized (TestServiceGrpc.class) {
if ((getStreamingOutputCallMethod = TestServiceGrpc.getStreamingOutputCallMethod) == null) { if ((getStreamingOutputCallMethod = TestServiceGrpc.getStreamingOutputCallMethod) == null) {
TestServiceGrpc.getStreamingOutputCallMethod = getStreamingOutputCallMethod = TestServiceGrpc.getStreamingOutputCallMethod = getStreamingOutputCallMethod =
io.grpc.MethodDescriptor.<io.grpc.testing.compiler.Test.StreamingOutputCallRequest, io.grpc.testing.compiler.Test.StreamingOutputCallResponse>newBuilder() io.grpc.MethodDescriptor.<io.grpc.testing.compiler.Test.StreamingOutputCallRequest, io.grpc.testing.compiler.Test.StreamingOutputCallResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING) .setType(io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(SERVICE_NAME, "StreamingOutputCall"))
"grpc.testing.compiler.TestService", "StreamingOutputCall"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.testing.compiler.Test.StreamingOutputCallRequest.getDefaultInstance())) io.grpc.testing.compiler.Test.StreamingOutputCallRequest.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.testing.compiler.Test.StreamingOutputCallResponse.getDefaultInstance())) io.grpc.testing.compiler.Test.StreamingOutputCallResponse.getDefaultInstance()))
.setSchemaDescriptor(new TestServiceMethodDescriptorSupplier("StreamingOutputCall")) .setSchemaDescriptor(new TestServiceMethodDescriptorSupplier("StreamingOutputCall"))
.build(); .build();
}
} }
} }
return getStreamingOutputCallMethod; }
return getStreamingOutputCallMethod;
} }
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingInputCallRequest, private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingInputCallRequest,
@ -108,22 +106,21 @@ public final class TestServiceGrpc {
if ((getStreamingInputCallMethod = TestServiceGrpc.getStreamingInputCallMethod) == null) { if ((getStreamingInputCallMethod = TestServiceGrpc.getStreamingInputCallMethod) == null) {
synchronized (TestServiceGrpc.class) { synchronized (TestServiceGrpc.class) {
if ((getStreamingInputCallMethod = TestServiceGrpc.getStreamingInputCallMethod) == null) { if ((getStreamingInputCallMethod = TestServiceGrpc.getStreamingInputCallMethod) == null) {
TestServiceGrpc.getStreamingInputCallMethod = getStreamingInputCallMethod = TestServiceGrpc.getStreamingInputCallMethod = getStreamingInputCallMethod =
io.grpc.MethodDescriptor.<io.grpc.testing.compiler.Test.StreamingInputCallRequest, io.grpc.testing.compiler.Test.StreamingInputCallResponse>newBuilder() io.grpc.MethodDescriptor.<io.grpc.testing.compiler.Test.StreamingInputCallRequest, io.grpc.testing.compiler.Test.StreamingInputCallResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.CLIENT_STREAMING) .setType(io.grpc.MethodDescriptor.MethodType.CLIENT_STREAMING)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(SERVICE_NAME, "StreamingInputCall"))
"grpc.testing.compiler.TestService", "StreamingInputCall"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.testing.compiler.Test.StreamingInputCallRequest.getDefaultInstance())) io.grpc.testing.compiler.Test.StreamingInputCallRequest.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.testing.compiler.Test.StreamingInputCallResponse.getDefaultInstance())) io.grpc.testing.compiler.Test.StreamingInputCallResponse.getDefaultInstance()))
.setSchemaDescriptor(new TestServiceMethodDescriptorSupplier("StreamingInputCall")) .setSchemaDescriptor(new TestServiceMethodDescriptorSupplier("StreamingInputCall"))
.build(); .build();
}
} }
} }
return getStreamingInputCallMethod; }
return getStreamingInputCallMethod;
} }
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest, private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
@ -140,22 +137,21 @@ public final class TestServiceGrpc {
if ((getFullBidiCallMethod = TestServiceGrpc.getFullBidiCallMethod) == null) { if ((getFullBidiCallMethod = TestServiceGrpc.getFullBidiCallMethod) == null) {
synchronized (TestServiceGrpc.class) { synchronized (TestServiceGrpc.class) {
if ((getFullBidiCallMethod = TestServiceGrpc.getFullBidiCallMethod) == null) { if ((getFullBidiCallMethod = TestServiceGrpc.getFullBidiCallMethod) == null) {
TestServiceGrpc.getFullBidiCallMethod = getFullBidiCallMethod = TestServiceGrpc.getFullBidiCallMethod = getFullBidiCallMethod =
io.grpc.MethodDescriptor.<io.grpc.testing.compiler.Test.StreamingOutputCallRequest, io.grpc.testing.compiler.Test.StreamingOutputCallResponse>newBuilder() io.grpc.MethodDescriptor.<io.grpc.testing.compiler.Test.StreamingOutputCallRequest, io.grpc.testing.compiler.Test.StreamingOutputCallResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING) .setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(SERVICE_NAME, "FullBidiCall"))
"grpc.testing.compiler.TestService", "FullBidiCall"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.testing.compiler.Test.StreamingOutputCallRequest.getDefaultInstance())) io.grpc.testing.compiler.Test.StreamingOutputCallRequest.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.testing.compiler.Test.StreamingOutputCallResponse.getDefaultInstance())) io.grpc.testing.compiler.Test.StreamingOutputCallResponse.getDefaultInstance()))
.setSchemaDescriptor(new TestServiceMethodDescriptorSupplier("FullBidiCall")) .setSchemaDescriptor(new TestServiceMethodDescriptorSupplier("FullBidiCall"))
.build(); .build();
}
} }
} }
return getFullBidiCallMethod; }
return getFullBidiCallMethod;
} }
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest, private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
@ -172,22 +168,21 @@ public final class TestServiceGrpc {
if ((getHalfBidiCallMethod = TestServiceGrpc.getHalfBidiCallMethod) == null) { if ((getHalfBidiCallMethod = TestServiceGrpc.getHalfBidiCallMethod) == null) {
synchronized (TestServiceGrpc.class) { synchronized (TestServiceGrpc.class) {
if ((getHalfBidiCallMethod = TestServiceGrpc.getHalfBidiCallMethod) == null) { if ((getHalfBidiCallMethod = TestServiceGrpc.getHalfBidiCallMethod) == null) {
TestServiceGrpc.getHalfBidiCallMethod = getHalfBidiCallMethod = TestServiceGrpc.getHalfBidiCallMethod = getHalfBidiCallMethod =
io.grpc.MethodDescriptor.<io.grpc.testing.compiler.Test.StreamingOutputCallRequest, io.grpc.testing.compiler.Test.StreamingOutputCallResponse>newBuilder() io.grpc.MethodDescriptor.<io.grpc.testing.compiler.Test.StreamingOutputCallRequest, io.grpc.testing.compiler.Test.StreamingOutputCallResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING) .setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(SERVICE_NAME, "HalfBidiCall"))
"grpc.testing.compiler.TestService", "HalfBidiCall"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.testing.compiler.Test.StreamingOutputCallRequest.getDefaultInstance())) io.grpc.testing.compiler.Test.StreamingOutputCallRequest.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.testing.compiler.Test.StreamingOutputCallResponse.getDefaultInstance())) io.grpc.testing.compiler.Test.StreamingOutputCallResponse.getDefaultInstance()))
.setSchemaDescriptor(new TestServiceMethodDescriptorSupplier("HalfBidiCall")) .setSchemaDescriptor(new TestServiceMethodDescriptorSupplier("HalfBidiCall"))
.build(); .build();
}
} }
} }
return getHalfBidiCallMethod; }
return getHalfBidiCallMethod;
} }
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingInputCallRequest, private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingInputCallRequest,
@ -204,22 +199,21 @@ public final class TestServiceGrpc {
if ((getImportMethod = TestServiceGrpc.getImportMethod) == null) { if ((getImportMethod = TestServiceGrpc.getImportMethod) == null) {
synchronized (TestServiceGrpc.class) { synchronized (TestServiceGrpc.class) {
if ((getImportMethod = TestServiceGrpc.getImportMethod) == null) { if ((getImportMethod = TestServiceGrpc.getImportMethod) == null) {
TestServiceGrpc.getImportMethod = getImportMethod = TestServiceGrpc.getImportMethod = getImportMethod =
io.grpc.MethodDescriptor.<io.grpc.testing.compiler.Test.StreamingInputCallRequest, io.grpc.testing.compiler.Test.StreamingInputCallResponse>newBuilder() io.grpc.MethodDescriptor.<io.grpc.testing.compiler.Test.StreamingInputCallRequest, io.grpc.testing.compiler.Test.StreamingInputCallResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING) .setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(SERVICE_NAME, "Import"))
"grpc.testing.compiler.TestService", "Import"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.testing.compiler.Test.StreamingInputCallRequest.getDefaultInstance())) io.grpc.testing.compiler.Test.StreamingInputCallRequest.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.testing.compiler.Test.StreamingInputCallResponse.getDefaultInstance())) io.grpc.testing.compiler.Test.StreamingInputCallResponse.getDefaultInstance()))
.setSchemaDescriptor(new TestServiceMethodDescriptorSupplier("Import")) .setSchemaDescriptor(new TestServiceMethodDescriptorSupplier("Import"))
.build(); .build();
}
} }
} }
return getImportMethod; }
return getImportMethod;
} }
/** /**

View File

@ -45,21 +45,20 @@ public final class TestDeprecatedServiceGrpc {
if ((getDeprecatedMethodMethod = TestDeprecatedServiceGrpc.getDeprecatedMethodMethod) == null) { if ((getDeprecatedMethodMethod = TestDeprecatedServiceGrpc.getDeprecatedMethodMethod) == null) {
synchronized (TestDeprecatedServiceGrpc.class) { synchronized (TestDeprecatedServiceGrpc.class) {
if ((getDeprecatedMethodMethod = TestDeprecatedServiceGrpc.getDeprecatedMethodMethod) == null) { if ((getDeprecatedMethodMethod = TestDeprecatedServiceGrpc.getDeprecatedMethodMethod) == null) {
TestDeprecatedServiceGrpc.getDeprecatedMethodMethod = getDeprecatedMethodMethod = TestDeprecatedServiceGrpc.getDeprecatedMethodMethod = getDeprecatedMethodMethod =
io.grpc.MethodDescriptor.<io.grpc.testing.compiler.Test.SimpleRequest, io.grpc.testing.compiler.Test.SimpleResponse>newBuilder() io.grpc.MethodDescriptor.<io.grpc.testing.compiler.Test.SimpleRequest, io.grpc.testing.compiler.Test.SimpleResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.UNARY) .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(SERVICE_NAME, "DeprecatedMethod"))
"grpc.testing.compiler.TestDeprecatedService", "DeprecatedMethod"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(
io.grpc.testing.compiler.Test.SimpleRequest.getDefaultInstance())) io.grpc.testing.compiler.Test.SimpleRequest.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(
io.grpc.testing.compiler.Test.SimpleResponse.getDefaultInstance())) io.grpc.testing.compiler.Test.SimpleResponse.getDefaultInstance()))
.build(); .build();
}
} }
} }
return getDeprecatedMethodMethod; }
return getDeprecatedMethodMethod;
} }
/** /**

View File

@ -44,21 +44,20 @@ public final class TestServiceGrpc {
if ((getUnaryCallMethod = TestServiceGrpc.getUnaryCallMethod) == null) { if ((getUnaryCallMethod = TestServiceGrpc.getUnaryCallMethod) == null) {
synchronized (TestServiceGrpc.class) { synchronized (TestServiceGrpc.class) {
if ((getUnaryCallMethod = TestServiceGrpc.getUnaryCallMethod) == null) { if ((getUnaryCallMethod = TestServiceGrpc.getUnaryCallMethod) == null) {
TestServiceGrpc.getUnaryCallMethod = getUnaryCallMethod = TestServiceGrpc.getUnaryCallMethod = getUnaryCallMethod =
io.grpc.MethodDescriptor.<io.grpc.testing.compiler.Test.SimpleRequest, io.grpc.testing.compiler.Test.SimpleResponse>newBuilder() io.grpc.MethodDescriptor.<io.grpc.testing.compiler.Test.SimpleRequest, io.grpc.testing.compiler.Test.SimpleResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.UNARY) .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(SERVICE_NAME, "UnaryCall"))
"grpc.testing.compiler.TestService", "UnaryCall"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(
io.grpc.testing.compiler.Test.SimpleRequest.getDefaultInstance())) io.grpc.testing.compiler.Test.SimpleRequest.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(
io.grpc.testing.compiler.Test.SimpleResponse.getDefaultInstance())) io.grpc.testing.compiler.Test.SimpleResponse.getDefaultInstance()))
.build(); .build();
}
} }
} }
return getUnaryCallMethod; }
return getUnaryCallMethod;
} }
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest, private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
@ -75,21 +74,20 @@ public final class TestServiceGrpc {
if ((getStreamingOutputCallMethod = TestServiceGrpc.getStreamingOutputCallMethod) == null) { if ((getStreamingOutputCallMethod = TestServiceGrpc.getStreamingOutputCallMethod) == null) {
synchronized (TestServiceGrpc.class) { synchronized (TestServiceGrpc.class) {
if ((getStreamingOutputCallMethod = TestServiceGrpc.getStreamingOutputCallMethod) == null) { if ((getStreamingOutputCallMethod = TestServiceGrpc.getStreamingOutputCallMethod) == null) {
TestServiceGrpc.getStreamingOutputCallMethod = getStreamingOutputCallMethod = TestServiceGrpc.getStreamingOutputCallMethod = getStreamingOutputCallMethod =
io.grpc.MethodDescriptor.<io.grpc.testing.compiler.Test.StreamingOutputCallRequest, io.grpc.testing.compiler.Test.StreamingOutputCallResponse>newBuilder() io.grpc.MethodDescriptor.<io.grpc.testing.compiler.Test.StreamingOutputCallRequest, io.grpc.testing.compiler.Test.StreamingOutputCallResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING) .setType(io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(SERVICE_NAME, "StreamingOutputCall"))
"grpc.testing.compiler.TestService", "StreamingOutputCall"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(
io.grpc.testing.compiler.Test.StreamingOutputCallRequest.getDefaultInstance())) io.grpc.testing.compiler.Test.StreamingOutputCallRequest.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(
io.grpc.testing.compiler.Test.StreamingOutputCallResponse.getDefaultInstance())) io.grpc.testing.compiler.Test.StreamingOutputCallResponse.getDefaultInstance()))
.build(); .build();
}
} }
} }
return getStreamingOutputCallMethod; }
return getStreamingOutputCallMethod;
} }
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingInputCallRequest, private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingInputCallRequest,
@ -106,21 +104,20 @@ public final class TestServiceGrpc {
if ((getStreamingInputCallMethod = TestServiceGrpc.getStreamingInputCallMethod) == null) { if ((getStreamingInputCallMethod = TestServiceGrpc.getStreamingInputCallMethod) == null) {
synchronized (TestServiceGrpc.class) { synchronized (TestServiceGrpc.class) {
if ((getStreamingInputCallMethod = TestServiceGrpc.getStreamingInputCallMethod) == null) { if ((getStreamingInputCallMethod = TestServiceGrpc.getStreamingInputCallMethod) == null) {
TestServiceGrpc.getStreamingInputCallMethod = getStreamingInputCallMethod = TestServiceGrpc.getStreamingInputCallMethod = getStreamingInputCallMethod =
io.grpc.MethodDescriptor.<io.grpc.testing.compiler.Test.StreamingInputCallRequest, io.grpc.testing.compiler.Test.StreamingInputCallResponse>newBuilder() io.grpc.MethodDescriptor.<io.grpc.testing.compiler.Test.StreamingInputCallRequest, io.grpc.testing.compiler.Test.StreamingInputCallResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.CLIENT_STREAMING) .setType(io.grpc.MethodDescriptor.MethodType.CLIENT_STREAMING)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(SERVICE_NAME, "StreamingInputCall"))
"grpc.testing.compiler.TestService", "StreamingInputCall"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(
io.grpc.testing.compiler.Test.StreamingInputCallRequest.getDefaultInstance())) io.grpc.testing.compiler.Test.StreamingInputCallRequest.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(
io.grpc.testing.compiler.Test.StreamingInputCallResponse.getDefaultInstance())) io.grpc.testing.compiler.Test.StreamingInputCallResponse.getDefaultInstance()))
.build(); .build();
}
} }
} }
return getStreamingInputCallMethod; }
return getStreamingInputCallMethod;
} }
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest, private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
@ -137,21 +134,20 @@ public final class TestServiceGrpc {
if ((getFullBidiCallMethod = TestServiceGrpc.getFullBidiCallMethod) == null) { if ((getFullBidiCallMethod = TestServiceGrpc.getFullBidiCallMethod) == null) {
synchronized (TestServiceGrpc.class) { synchronized (TestServiceGrpc.class) {
if ((getFullBidiCallMethod = TestServiceGrpc.getFullBidiCallMethod) == null) { if ((getFullBidiCallMethod = TestServiceGrpc.getFullBidiCallMethod) == null) {
TestServiceGrpc.getFullBidiCallMethod = getFullBidiCallMethod = TestServiceGrpc.getFullBidiCallMethod = getFullBidiCallMethod =
io.grpc.MethodDescriptor.<io.grpc.testing.compiler.Test.StreamingOutputCallRequest, io.grpc.testing.compiler.Test.StreamingOutputCallResponse>newBuilder() io.grpc.MethodDescriptor.<io.grpc.testing.compiler.Test.StreamingOutputCallRequest, io.grpc.testing.compiler.Test.StreamingOutputCallResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING) .setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(SERVICE_NAME, "FullBidiCall"))
"grpc.testing.compiler.TestService", "FullBidiCall"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(
io.grpc.testing.compiler.Test.StreamingOutputCallRequest.getDefaultInstance())) io.grpc.testing.compiler.Test.StreamingOutputCallRequest.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(
io.grpc.testing.compiler.Test.StreamingOutputCallResponse.getDefaultInstance())) io.grpc.testing.compiler.Test.StreamingOutputCallResponse.getDefaultInstance()))
.build(); .build();
}
} }
} }
return getFullBidiCallMethod; }
return getFullBidiCallMethod;
} }
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest, private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingOutputCallRequest,
@ -168,21 +164,20 @@ public final class TestServiceGrpc {
if ((getHalfBidiCallMethod = TestServiceGrpc.getHalfBidiCallMethod) == null) { if ((getHalfBidiCallMethod = TestServiceGrpc.getHalfBidiCallMethod) == null) {
synchronized (TestServiceGrpc.class) { synchronized (TestServiceGrpc.class) {
if ((getHalfBidiCallMethod = TestServiceGrpc.getHalfBidiCallMethod) == null) { if ((getHalfBidiCallMethod = TestServiceGrpc.getHalfBidiCallMethod) == null) {
TestServiceGrpc.getHalfBidiCallMethod = getHalfBidiCallMethod = TestServiceGrpc.getHalfBidiCallMethod = getHalfBidiCallMethod =
io.grpc.MethodDescriptor.<io.grpc.testing.compiler.Test.StreamingOutputCallRequest, io.grpc.testing.compiler.Test.StreamingOutputCallResponse>newBuilder() io.grpc.MethodDescriptor.<io.grpc.testing.compiler.Test.StreamingOutputCallRequest, io.grpc.testing.compiler.Test.StreamingOutputCallResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING) .setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(SERVICE_NAME, "HalfBidiCall"))
"grpc.testing.compiler.TestService", "HalfBidiCall"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(
io.grpc.testing.compiler.Test.StreamingOutputCallRequest.getDefaultInstance())) io.grpc.testing.compiler.Test.StreamingOutputCallRequest.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(
io.grpc.testing.compiler.Test.StreamingOutputCallResponse.getDefaultInstance())) io.grpc.testing.compiler.Test.StreamingOutputCallResponse.getDefaultInstance()))
.build(); .build();
}
} }
} }
return getHalfBidiCallMethod; }
return getHalfBidiCallMethod;
} }
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingInputCallRequest, private static volatile io.grpc.MethodDescriptor<io.grpc.testing.compiler.Test.StreamingInputCallRequest,
@ -199,21 +194,20 @@ public final class TestServiceGrpc {
if ((getImportMethod = TestServiceGrpc.getImportMethod) == null) { if ((getImportMethod = TestServiceGrpc.getImportMethod) == null) {
synchronized (TestServiceGrpc.class) { synchronized (TestServiceGrpc.class) {
if ((getImportMethod = TestServiceGrpc.getImportMethod) == null) { if ((getImportMethod = TestServiceGrpc.getImportMethod) == null) {
TestServiceGrpc.getImportMethod = getImportMethod = TestServiceGrpc.getImportMethod = getImportMethod =
io.grpc.MethodDescriptor.<io.grpc.testing.compiler.Test.StreamingInputCallRequest, io.grpc.testing.compiler.Test.StreamingInputCallResponse>newBuilder() io.grpc.MethodDescriptor.<io.grpc.testing.compiler.Test.StreamingInputCallRequest, io.grpc.testing.compiler.Test.StreamingInputCallResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING) .setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(SERVICE_NAME, "Import"))
"grpc.testing.compiler.TestService", "Import"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(
io.grpc.testing.compiler.Test.StreamingInputCallRequest.getDefaultInstance())) io.grpc.testing.compiler.Test.StreamingInputCallRequest.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(
io.grpc.testing.compiler.Test.StreamingInputCallResponse.getDefaultInstance())) io.grpc.testing.compiler.Test.StreamingInputCallResponse.getDefaultInstance()))
.build(); .build();
}
} }
} }
return getImportMethod; }
return getImportMethod;
} }
/** /**

View File

@ -41,22 +41,21 @@ public final class LoadBalancerGrpc {
if ((getBalanceLoadMethod = LoadBalancerGrpc.getBalanceLoadMethod) == null) { if ((getBalanceLoadMethod = LoadBalancerGrpc.getBalanceLoadMethod) == null) {
synchronized (LoadBalancerGrpc.class) { synchronized (LoadBalancerGrpc.class) {
if ((getBalanceLoadMethod = LoadBalancerGrpc.getBalanceLoadMethod) == null) { if ((getBalanceLoadMethod = LoadBalancerGrpc.getBalanceLoadMethod) == null) {
LoadBalancerGrpc.getBalanceLoadMethod = getBalanceLoadMethod = LoadBalancerGrpc.getBalanceLoadMethod = getBalanceLoadMethod =
io.grpc.MethodDescriptor.<io.grpc.lb.v1.LoadBalanceRequest, io.grpc.lb.v1.LoadBalanceResponse>newBuilder() io.grpc.MethodDescriptor.<io.grpc.lb.v1.LoadBalanceRequest, io.grpc.lb.v1.LoadBalanceResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING) .setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(SERVICE_NAME, "BalanceLoad"))
"grpc.lb.v1.LoadBalancer", "BalanceLoad"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.lb.v1.LoadBalanceRequest.getDefaultInstance())) io.grpc.lb.v1.LoadBalanceRequest.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.lb.v1.LoadBalanceResponse.getDefaultInstance())) io.grpc.lb.v1.LoadBalanceResponse.getDefaultInstance()))
.setSchemaDescriptor(new LoadBalancerMethodDescriptorSupplier("BalanceLoad")) .setSchemaDescriptor(new LoadBalancerMethodDescriptorSupplier("BalanceLoad"))
.build(); .build();
}
} }
} }
return getBalanceLoadMethod; }
return getBalanceLoadMethod;
} }
/** /**

View File

@ -41,22 +41,21 @@ public final class MetricsServiceGrpc {
if ((getGetAllGaugesMethod = MetricsServiceGrpc.getGetAllGaugesMethod) == null) { if ((getGetAllGaugesMethod = MetricsServiceGrpc.getGetAllGaugesMethod) == null) {
synchronized (MetricsServiceGrpc.class) { synchronized (MetricsServiceGrpc.class) {
if ((getGetAllGaugesMethod = MetricsServiceGrpc.getGetAllGaugesMethod) == null) { if ((getGetAllGaugesMethod = MetricsServiceGrpc.getGetAllGaugesMethod) == null) {
MetricsServiceGrpc.getGetAllGaugesMethod = getGetAllGaugesMethod = MetricsServiceGrpc.getGetAllGaugesMethod = getGetAllGaugesMethod =
io.grpc.MethodDescriptor.<io.grpc.testing.integration.Metrics.EmptyMessage, io.grpc.testing.integration.Metrics.GaugeResponse>newBuilder() io.grpc.MethodDescriptor.<io.grpc.testing.integration.Metrics.EmptyMessage, io.grpc.testing.integration.Metrics.GaugeResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING) .setType(io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(SERVICE_NAME, "GetAllGauges"))
"grpc.testing.MetricsService", "GetAllGauges"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.testing.integration.Metrics.EmptyMessage.getDefaultInstance())) io.grpc.testing.integration.Metrics.EmptyMessage.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.testing.integration.Metrics.GaugeResponse.getDefaultInstance())) io.grpc.testing.integration.Metrics.GaugeResponse.getDefaultInstance()))
.setSchemaDescriptor(new MetricsServiceMethodDescriptorSupplier("GetAllGauges")) .setSchemaDescriptor(new MetricsServiceMethodDescriptorSupplier("GetAllGauges"))
.build(); .build();
}
} }
} }
return getGetAllGaugesMethod; }
return getGetAllGaugesMethod;
} }
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.integration.Metrics.GaugeRequest, private static volatile io.grpc.MethodDescriptor<io.grpc.testing.integration.Metrics.GaugeRequest,
@ -73,22 +72,21 @@ public final class MetricsServiceGrpc {
if ((getGetGaugeMethod = MetricsServiceGrpc.getGetGaugeMethod) == null) { if ((getGetGaugeMethod = MetricsServiceGrpc.getGetGaugeMethod) == null) {
synchronized (MetricsServiceGrpc.class) { synchronized (MetricsServiceGrpc.class) {
if ((getGetGaugeMethod = MetricsServiceGrpc.getGetGaugeMethod) == null) { if ((getGetGaugeMethod = MetricsServiceGrpc.getGetGaugeMethod) == null) {
MetricsServiceGrpc.getGetGaugeMethod = getGetGaugeMethod = MetricsServiceGrpc.getGetGaugeMethod = getGetGaugeMethod =
io.grpc.MethodDescriptor.<io.grpc.testing.integration.Metrics.GaugeRequest, io.grpc.testing.integration.Metrics.GaugeResponse>newBuilder() io.grpc.MethodDescriptor.<io.grpc.testing.integration.Metrics.GaugeRequest, io.grpc.testing.integration.Metrics.GaugeResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.UNARY) .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(SERVICE_NAME, "GetGauge"))
"grpc.testing.MetricsService", "GetGauge"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.testing.integration.Metrics.GaugeRequest.getDefaultInstance())) io.grpc.testing.integration.Metrics.GaugeRequest.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.testing.integration.Metrics.GaugeResponse.getDefaultInstance())) io.grpc.testing.integration.Metrics.GaugeResponse.getDefaultInstance()))
.setSchemaDescriptor(new MetricsServiceMethodDescriptorSupplier("GetGauge")) .setSchemaDescriptor(new MetricsServiceMethodDescriptorSupplier("GetGauge"))
.build(); .build();
}
} }
} }
return getGetGaugeMethod; }
return getGetGaugeMethod;
} }
/** /**

View File

@ -44,22 +44,21 @@ public final class ReconnectServiceGrpc {
if ((getStartMethod = ReconnectServiceGrpc.getStartMethod) == null) { if ((getStartMethod = ReconnectServiceGrpc.getStartMethod) == null) {
synchronized (ReconnectServiceGrpc.class) { synchronized (ReconnectServiceGrpc.class) {
if ((getStartMethod = ReconnectServiceGrpc.getStartMethod) == null) { if ((getStartMethod = ReconnectServiceGrpc.getStartMethod) == null) {
ReconnectServiceGrpc.getStartMethod = getStartMethod = ReconnectServiceGrpc.getStartMethod = getStartMethod =
io.grpc.MethodDescriptor.<io.grpc.testing.integration.EmptyProtos.Empty, io.grpc.testing.integration.EmptyProtos.Empty>newBuilder() io.grpc.MethodDescriptor.<io.grpc.testing.integration.EmptyProtos.Empty, io.grpc.testing.integration.EmptyProtos.Empty>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.UNARY) .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(SERVICE_NAME, "Start"))
"grpc.testing.ReconnectService", "Start"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.testing.integration.EmptyProtos.Empty.getDefaultInstance())) io.grpc.testing.integration.EmptyProtos.Empty.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.testing.integration.EmptyProtos.Empty.getDefaultInstance())) io.grpc.testing.integration.EmptyProtos.Empty.getDefaultInstance()))
.setSchemaDescriptor(new ReconnectServiceMethodDescriptorSupplier("Start")) .setSchemaDescriptor(new ReconnectServiceMethodDescriptorSupplier("Start"))
.build(); .build();
}
} }
} }
return getStartMethod; }
return getStartMethod;
} }
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.integration.EmptyProtos.Empty, private static volatile io.grpc.MethodDescriptor<io.grpc.testing.integration.EmptyProtos.Empty,
@ -76,22 +75,21 @@ public final class ReconnectServiceGrpc {
if ((getStopMethod = ReconnectServiceGrpc.getStopMethod) == null) { if ((getStopMethod = ReconnectServiceGrpc.getStopMethod) == null) {
synchronized (ReconnectServiceGrpc.class) { synchronized (ReconnectServiceGrpc.class) {
if ((getStopMethod = ReconnectServiceGrpc.getStopMethod) == null) { if ((getStopMethod = ReconnectServiceGrpc.getStopMethod) == null) {
ReconnectServiceGrpc.getStopMethod = getStopMethod = ReconnectServiceGrpc.getStopMethod = getStopMethod =
io.grpc.MethodDescriptor.<io.grpc.testing.integration.EmptyProtos.Empty, io.grpc.testing.integration.Messages.ReconnectInfo>newBuilder() io.grpc.MethodDescriptor.<io.grpc.testing.integration.EmptyProtos.Empty, io.grpc.testing.integration.Messages.ReconnectInfo>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.UNARY) .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(SERVICE_NAME, "Stop"))
"grpc.testing.ReconnectService", "Stop"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.testing.integration.EmptyProtos.Empty.getDefaultInstance())) io.grpc.testing.integration.EmptyProtos.Empty.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.testing.integration.Messages.ReconnectInfo.getDefaultInstance())) io.grpc.testing.integration.Messages.ReconnectInfo.getDefaultInstance()))
.setSchemaDescriptor(new ReconnectServiceMethodDescriptorSupplier("Stop")) .setSchemaDescriptor(new ReconnectServiceMethodDescriptorSupplier("Stop"))
.build(); .build();
}
} }
} }
return getStopMethod; }
return getStopMethod;
} }
/** /**

View File

@ -45,22 +45,21 @@ public final class TestServiceGrpc {
if ((getEmptyCallMethod = TestServiceGrpc.getEmptyCallMethod) == null) { if ((getEmptyCallMethod = TestServiceGrpc.getEmptyCallMethod) == null) {
synchronized (TestServiceGrpc.class) { synchronized (TestServiceGrpc.class) {
if ((getEmptyCallMethod = TestServiceGrpc.getEmptyCallMethod) == null) { if ((getEmptyCallMethod = TestServiceGrpc.getEmptyCallMethod) == null) {
TestServiceGrpc.getEmptyCallMethod = getEmptyCallMethod = TestServiceGrpc.getEmptyCallMethod = getEmptyCallMethod =
io.grpc.MethodDescriptor.<io.grpc.testing.integration.EmptyProtos.Empty, io.grpc.testing.integration.EmptyProtos.Empty>newBuilder() io.grpc.MethodDescriptor.<io.grpc.testing.integration.EmptyProtos.Empty, io.grpc.testing.integration.EmptyProtos.Empty>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.UNARY) .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(SERVICE_NAME, "EmptyCall"))
"grpc.testing.TestService", "EmptyCall"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.testing.integration.EmptyProtos.Empty.getDefaultInstance())) io.grpc.testing.integration.EmptyProtos.Empty.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.testing.integration.EmptyProtos.Empty.getDefaultInstance())) io.grpc.testing.integration.EmptyProtos.Empty.getDefaultInstance()))
.setSchemaDescriptor(new TestServiceMethodDescriptorSupplier("EmptyCall")) .setSchemaDescriptor(new TestServiceMethodDescriptorSupplier("EmptyCall"))
.build(); .build();
}
} }
} }
return getEmptyCallMethod; }
return getEmptyCallMethod;
} }
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.SimpleRequest, private static volatile io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.SimpleRequest,
@ -77,22 +76,21 @@ public final class TestServiceGrpc {
if ((getUnaryCallMethod = TestServiceGrpc.getUnaryCallMethod) == null) { if ((getUnaryCallMethod = TestServiceGrpc.getUnaryCallMethod) == null) {
synchronized (TestServiceGrpc.class) { synchronized (TestServiceGrpc.class) {
if ((getUnaryCallMethod = TestServiceGrpc.getUnaryCallMethod) == null) { if ((getUnaryCallMethod = TestServiceGrpc.getUnaryCallMethod) == null) {
TestServiceGrpc.getUnaryCallMethod = getUnaryCallMethod = TestServiceGrpc.getUnaryCallMethod = getUnaryCallMethod =
io.grpc.MethodDescriptor.<io.grpc.testing.integration.Messages.SimpleRequest, io.grpc.testing.integration.Messages.SimpleResponse>newBuilder() io.grpc.MethodDescriptor.<io.grpc.testing.integration.Messages.SimpleRequest, io.grpc.testing.integration.Messages.SimpleResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.UNARY) .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(SERVICE_NAME, "UnaryCall"))
"grpc.testing.TestService", "UnaryCall"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.testing.integration.Messages.SimpleRequest.getDefaultInstance())) io.grpc.testing.integration.Messages.SimpleRequest.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.testing.integration.Messages.SimpleResponse.getDefaultInstance())) io.grpc.testing.integration.Messages.SimpleResponse.getDefaultInstance()))
.setSchemaDescriptor(new TestServiceMethodDescriptorSupplier("UnaryCall")) .setSchemaDescriptor(new TestServiceMethodDescriptorSupplier("UnaryCall"))
.build(); .build();
}
} }
} }
return getUnaryCallMethod; }
return getUnaryCallMethod;
} }
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.SimpleRequest, private static volatile io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.SimpleRequest,
@ -109,22 +107,21 @@ public final class TestServiceGrpc {
if ((getCacheableUnaryCallMethod = TestServiceGrpc.getCacheableUnaryCallMethod) == null) { if ((getCacheableUnaryCallMethod = TestServiceGrpc.getCacheableUnaryCallMethod) == null) {
synchronized (TestServiceGrpc.class) { synchronized (TestServiceGrpc.class) {
if ((getCacheableUnaryCallMethod = TestServiceGrpc.getCacheableUnaryCallMethod) == null) { if ((getCacheableUnaryCallMethod = TestServiceGrpc.getCacheableUnaryCallMethod) == null) {
TestServiceGrpc.getCacheableUnaryCallMethod = getCacheableUnaryCallMethod = TestServiceGrpc.getCacheableUnaryCallMethod = getCacheableUnaryCallMethod =
io.grpc.MethodDescriptor.<io.grpc.testing.integration.Messages.SimpleRequest, io.grpc.testing.integration.Messages.SimpleResponse>newBuilder() io.grpc.MethodDescriptor.<io.grpc.testing.integration.Messages.SimpleRequest, io.grpc.testing.integration.Messages.SimpleResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.UNARY) .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(SERVICE_NAME, "CacheableUnaryCall"))
"grpc.testing.TestService", "CacheableUnaryCall"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.testing.integration.Messages.SimpleRequest.getDefaultInstance())) io.grpc.testing.integration.Messages.SimpleRequest.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.testing.integration.Messages.SimpleResponse.getDefaultInstance())) io.grpc.testing.integration.Messages.SimpleResponse.getDefaultInstance()))
.setSchemaDescriptor(new TestServiceMethodDescriptorSupplier("CacheableUnaryCall")) .setSchemaDescriptor(new TestServiceMethodDescriptorSupplier("CacheableUnaryCall"))
.build(); .build();
}
} }
} }
return getCacheableUnaryCallMethod; }
return getCacheableUnaryCallMethod;
} }
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.StreamingOutputCallRequest, private static volatile io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.StreamingOutputCallRequest,
@ -141,22 +138,21 @@ public final class TestServiceGrpc {
if ((getStreamingOutputCallMethod = TestServiceGrpc.getStreamingOutputCallMethod) == null) { if ((getStreamingOutputCallMethod = TestServiceGrpc.getStreamingOutputCallMethod) == null) {
synchronized (TestServiceGrpc.class) { synchronized (TestServiceGrpc.class) {
if ((getStreamingOutputCallMethod = TestServiceGrpc.getStreamingOutputCallMethod) == null) { if ((getStreamingOutputCallMethod = TestServiceGrpc.getStreamingOutputCallMethod) == null) {
TestServiceGrpc.getStreamingOutputCallMethod = getStreamingOutputCallMethod = TestServiceGrpc.getStreamingOutputCallMethod = getStreamingOutputCallMethod =
io.grpc.MethodDescriptor.<io.grpc.testing.integration.Messages.StreamingOutputCallRequest, io.grpc.testing.integration.Messages.StreamingOutputCallResponse>newBuilder() io.grpc.MethodDescriptor.<io.grpc.testing.integration.Messages.StreamingOutputCallRequest, io.grpc.testing.integration.Messages.StreamingOutputCallResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING) .setType(io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(SERVICE_NAME, "StreamingOutputCall"))
"grpc.testing.TestService", "StreamingOutputCall"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.testing.integration.Messages.StreamingOutputCallRequest.getDefaultInstance())) io.grpc.testing.integration.Messages.StreamingOutputCallRequest.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.testing.integration.Messages.StreamingOutputCallResponse.getDefaultInstance())) io.grpc.testing.integration.Messages.StreamingOutputCallResponse.getDefaultInstance()))
.setSchemaDescriptor(new TestServiceMethodDescriptorSupplier("StreamingOutputCall")) .setSchemaDescriptor(new TestServiceMethodDescriptorSupplier("StreamingOutputCall"))
.build(); .build();
}
} }
} }
return getStreamingOutputCallMethod; }
return getStreamingOutputCallMethod;
} }
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.StreamingInputCallRequest, private static volatile io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.StreamingInputCallRequest,
@ -173,22 +169,21 @@ public final class TestServiceGrpc {
if ((getStreamingInputCallMethod = TestServiceGrpc.getStreamingInputCallMethod) == null) { if ((getStreamingInputCallMethod = TestServiceGrpc.getStreamingInputCallMethod) == null) {
synchronized (TestServiceGrpc.class) { synchronized (TestServiceGrpc.class) {
if ((getStreamingInputCallMethod = TestServiceGrpc.getStreamingInputCallMethod) == null) { if ((getStreamingInputCallMethod = TestServiceGrpc.getStreamingInputCallMethod) == null) {
TestServiceGrpc.getStreamingInputCallMethod = getStreamingInputCallMethod = TestServiceGrpc.getStreamingInputCallMethod = getStreamingInputCallMethod =
io.grpc.MethodDescriptor.<io.grpc.testing.integration.Messages.StreamingInputCallRequest, io.grpc.testing.integration.Messages.StreamingInputCallResponse>newBuilder() io.grpc.MethodDescriptor.<io.grpc.testing.integration.Messages.StreamingInputCallRequest, io.grpc.testing.integration.Messages.StreamingInputCallResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.CLIENT_STREAMING) .setType(io.grpc.MethodDescriptor.MethodType.CLIENT_STREAMING)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(SERVICE_NAME, "StreamingInputCall"))
"grpc.testing.TestService", "StreamingInputCall"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.testing.integration.Messages.StreamingInputCallRequest.getDefaultInstance())) io.grpc.testing.integration.Messages.StreamingInputCallRequest.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.testing.integration.Messages.StreamingInputCallResponse.getDefaultInstance())) io.grpc.testing.integration.Messages.StreamingInputCallResponse.getDefaultInstance()))
.setSchemaDescriptor(new TestServiceMethodDescriptorSupplier("StreamingInputCall")) .setSchemaDescriptor(new TestServiceMethodDescriptorSupplier("StreamingInputCall"))
.build(); .build();
}
} }
} }
return getStreamingInputCallMethod; }
return getStreamingInputCallMethod;
} }
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.StreamingOutputCallRequest, private static volatile io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.StreamingOutputCallRequest,
@ -205,22 +200,21 @@ public final class TestServiceGrpc {
if ((getFullDuplexCallMethod = TestServiceGrpc.getFullDuplexCallMethod) == null) { if ((getFullDuplexCallMethod = TestServiceGrpc.getFullDuplexCallMethod) == null) {
synchronized (TestServiceGrpc.class) { synchronized (TestServiceGrpc.class) {
if ((getFullDuplexCallMethod = TestServiceGrpc.getFullDuplexCallMethod) == null) { if ((getFullDuplexCallMethod = TestServiceGrpc.getFullDuplexCallMethod) == null) {
TestServiceGrpc.getFullDuplexCallMethod = getFullDuplexCallMethod = TestServiceGrpc.getFullDuplexCallMethod = getFullDuplexCallMethod =
io.grpc.MethodDescriptor.<io.grpc.testing.integration.Messages.StreamingOutputCallRequest, io.grpc.testing.integration.Messages.StreamingOutputCallResponse>newBuilder() io.grpc.MethodDescriptor.<io.grpc.testing.integration.Messages.StreamingOutputCallRequest, io.grpc.testing.integration.Messages.StreamingOutputCallResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING) .setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(SERVICE_NAME, "FullDuplexCall"))
"grpc.testing.TestService", "FullDuplexCall"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.testing.integration.Messages.StreamingOutputCallRequest.getDefaultInstance())) io.grpc.testing.integration.Messages.StreamingOutputCallRequest.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.testing.integration.Messages.StreamingOutputCallResponse.getDefaultInstance())) io.grpc.testing.integration.Messages.StreamingOutputCallResponse.getDefaultInstance()))
.setSchemaDescriptor(new TestServiceMethodDescriptorSupplier("FullDuplexCall")) .setSchemaDescriptor(new TestServiceMethodDescriptorSupplier("FullDuplexCall"))
.build(); .build();
}
} }
} }
return getFullDuplexCallMethod; }
return getFullDuplexCallMethod;
} }
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.StreamingOutputCallRequest, private static volatile io.grpc.MethodDescriptor<io.grpc.testing.integration.Messages.StreamingOutputCallRequest,
@ -237,22 +231,21 @@ public final class TestServiceGrpc {
if ((getHalfDuplexCallMethod = TestServiceGrpc.getHalfDuplexCallMethod) == null) { if ((getHalfDuplexCallMethod = TestServiceGrpc.getHalfDuplexCallMethod) == null) {
synchronized (TestServiceGrpc.class) { synchronized (TestServiceGrpc.class) {
if ((getHalfDuplexCallMethod = TestServiceGrpc.getHalfDuplexCallMethod) == null) { if ((getHalfDuplexCallMethod = TestServiceGrpc.getHalfDuplexCallMethod) == null) {
TestServiceGrpc.getHalfDuplexCallMethod = getHalfDuplexCallMethod = TestServiceGrpc.getHalfDuplexCallMethod = getHalfDuplexCallMethod =
io.grpc.MethodDescriptor.<io.grpc.testing.integration.Messages.StreamingOutputCallRequest, io.grpc.testing.integration.Messages.StreamingOutputCallResponse>newBuilder() io.grpc.MethodDescriptor.<io.grpc.testing.integration.Messages.StreamingOutputCallRequest, io.grpc.testing.integration.Messages.StreamingOutputCallResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING) .setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(SERVICE_NAME, "HalfDuplexCall"))
"grpc.testing.TestService", "HalfDuplexCall"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.testing.integration.Messages.StreamingOutputCallRequest.getDefaultInstance())) io.grpc.testing.integration.Messages.StreamingOutputCallRequest.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.testing.integration.Messages.StreamingOutputCallResponse.getDefaultInstance())) io.grpc.testing.integration.Messages.StreamingOutputCallResponse.getDefaultInstance()))
.setSchemaDescriptor(new TestServiceMethodDescriptorSupplier("HalfDuplexCall")) .setSchemaDescriptor(new TestServiceMethodDescriptorSupplier("HalfDuplexCall"))
.build(); .build();
}
} }
} }
return getHalfDuplexCallMethod; }
return getHalfDuplexCallMethod;
} }
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.integration.EmptyProtos.Empty, private static volatile io.grpc.MethodDescriptor<io.grpc.testing.integration.EmptyProtos.Empty,
@ -269,22 +262,21 @@ public final class TestServiceGrpc {
if ((getUnimplementedCallMethod = TestServiceGrpc.getUnimplementedCallMethod) == null) { if ((getUnimplementedCallMethod = TestServiceGrpc.getUnimplementedCallMethod) == null) {
synchronized (TestServiceGrpc.class) { synchronized (TestServiceGrpc.class) {
if ((getUnimplementedCallMethod = TestServiceGrpc.getUnimplementedCallMethod) == null) { if ((getUnimplementedCallMethod = TestServiceGrpc.getUnimplementedCallMethod) == null) {
TestServiceGrpc.getUnimplementedCallMethod = getUnimplementedCallMethod = TestServiceGrpc.getUnimplementedCallMethod = getUnimplementedCallMethod =
io.grpc.MethodDescriptor.<io.grpc.testing.integration.EmptyProtos.Empty, io.grpc.testing.integration.EmptyProtos.Empty>newBuilder() io.grpc.MethodDescriptor.<io.grpc.testing.integration.EmptyProtos.Empty, io.grpc.testing.integration.EmptyProtos.Empty>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.UNARY) .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(SERVICE_NAME, "UnimplementedCall"))
"grpc.testing.TestService", "UnimplementedCall"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.testing.integration.EmptyProtos.Empty.getDefaultInstance())) io.grpc.testing.integration.EmptyProtos.Empty.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.testing.integration.EmptyProtos.Empty.getDefaultInstance())) io.grpc.testing.integration.EmptyProtos.Empty.getDefaultInstance()))
.setSchemaDescriptor(new TestServiceMethodDescriptorSupplier("UnimplementedCall")) .setSchemaDescriptor(new TestServiceMethodDescriptorSupplier("UnimplementedCall"))
.build(); .build();
}
} }
} }
return getUnimplementedCallMethod; }
return getUnimplementedCallMethod;
} }
/** /**

View File

@ -45,22 +45,21 @@ public final class UnimplementedServiceGrpc {
if ((getUnimplementedCallMethod = UnimplementedServiceGrpc.getUnimplementedCallMethod) == null) { if ((getUnimplementedCallMethod = UnimplementedServiceGrpc.getUnimplementedCallMethod) == null) {
synchronized (UnimplementedServiceGrpc.class) { synchronized (UnimplementedServiceGrpc.class) {
if ((getUnimplementedCallMethod = UnimplementedServiceGrpc.getUnimplementedCallMethod) == null) { if ((getUnimplementedCallMethod = UnimplementedServiceGrpc.getUnimplementedCallMethod) == null) {
UnimplementedServiceGrpc.getUnimplementedCallMethod = getUnimplementedCallMethod = UnimplementedServiceGrpc.getUnimplementedCallMethod = getUnimplementedCallMethod =
io.grpc.MethodDescriptor.<io.grpc.testing.integration.EmptyProtos.Empty, io.grpc.testing.integration.EmptyProtos.Empty>newBuilder() io.grpc.MethodDescriptor.<io.grpc.testing.integration.EmptyProtos.Empty, io.grpc.testing.integration.EmptyProtos.Empty>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.UNARY) .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(SERVICE_NAME, "UnimplementedCall"))
"grpc.testing.UnimplementedService", "UnimplementedCall"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.testing.integration.EmptyProtos.Empty.getDefaultInstance())) io.grpc.testing.integration.EmptyProtos.Empty.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.testing.integration.EmptyProtos.Empty.getDefaultInstance())) io.grpc.testing.integration.EmptyProtos.Empty.getDefaultInstance()))
.setSchemaDescriptor(new UnimplementedServiceMethodDescriptorSupplier("UnimplementedCall")) .setSchemaDescriptor(new UnimplementedServiceMethodDescriptorSupplier("UnimplementedCall"))
.build(); .build();
}
} }
} }
return getUnimplementedCallMethod; }
return getUnimplementedCallMethod;
} }
/** /**

View File

@ -45,22 +45,21 @@ public final class ChannelzGrpc {
if ((getGetTopChannelsMethod = ChannelzGrpc.getGetTopChannelsMethod) == null) { if ((getGetTopChannelsMethod = ChannelzGrpc.getGetTopChannelsMethod) == null) {
synchronized (ChannelzGrpc.class) { synchronized (ChannelzGrpc.class) {
if ((getGetTopChannelsMethod = ChannelzGrpc.getGetTopChannelsMethod) == null) { if ((getGetTopChannelsMethod = ChannelzGrpc.getGetTopChannelsMethod) == null) {
ChannelzGrpc.getGetTopChannelsMethod = getGetTopChannelsMethod = ChannelzGrpc.getGetTopChannelsMethod = getGetTopChannelsMethod =
io.grpc.MethodDescriptor.<io.grpc.channelz.v1.GetTopChannelsRequest, io.grpc.channelz.v1.GetTopChannelsResponse>newBuilder() io.grpc.MethodDescriptor.<io.grpc.channelz.v1.GetTopChannelsRequest, io.grpc.channelz.v1.GetTopChannelsResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.UNARY) .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(SERVICE_NAME, "GetTopChannels"))
"grpc.channelz.v1.Channelz", "GetTopChannels"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.channelz.v1.GetTopChannelsRequest.getDefaultInstance())) io.grpc.channelz.v1.GetTopChannelsRequest.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.channelz.v1.GetTopChannelsResponse.getDefaultInstance())) io.grpc.channelz.v1.GetTopChannelsResponse.getDefaultInstance()))
.setSchemaDescriptor(new ChannelzMethodDescriptorSupplier("GetTopChannels")) .setSchemaDescriptor(new ChannelzMethodDescriptorSupplier("GetTopChannels"))
.build(); .build();
}
} }
} }
return getGetTopChannelsMethod; }
return getGetTopChannelsMethod;
} }
private static volatile io.grpc.MethodDescriptor<io.grpc.channelz.v1.GetServersRequest, private static volatile io.grpc.MethodDescriptor<io.grpc.channelz.v1.GetServersRequest,
@ -77,22 +76,21 @@ public final class ChannelzGrpc {
if ((getGetServersMethod = ChannelzGrpc.getGetServersMethod) == null) { if ((getGetServersMethod = ChannelzGrpc.getGetServersMethod) == null) {
synchronized (ChannelzGrpc.class) { synchronized (ChannelzGrpc.class) {
if ((getGetServersMethod = ChannelzGrpc.getGetServersMethod) == null) { if ((getGetServersMethod = ChannelzGrpc.getGetServersMethod) == null) {
ChannelzGrpc.getGetServersMethod = getGetServersMethod = ChannelzGrpc.getGetServersMethod = getGetServersMethod =
io.grpc.MethodDescriptor.<io.grpc.channelz.v1.GetServersRequest, io.grpc.channelz.v1.GetServersResponse>newBuilder() io.grpc.MethodDescriptor.<io.grpc.channelz.v1.GetServersRequest, io.grpc.channelz.v1.GetServersResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.UNARY) .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(SERVICE_NAME, "GetServers"))
"grpc.channelz.v1.Channelz", "GetServers"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.channelz.v1.GetServersRequest.getDefaultInstance())) io.grpc.channelz.v1.GetServersRequest.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.channelz.v1.GetServersResponse.getDefaultInstance())) io.grpc.channelz.v1.GetServersResponse.getDefaultInstance()))
.setSchemaDescriptor(new ChannelzMethodDescriptorSupplier("GetServers")) .setSchemaDescriptor(new ChannelzMethodDescriptorSupplier("GetServers"))
.build(); .build();
}
} }
} }
return getGetServersMethod; }
return getGetServersMethod;
} }
private static volatile io.grpc.MethodDescriptor<io.grpc.channelz.v1.GetServerRequest, private static volatile io.grpc.MethodDescriptor<io.grpc.channelz.v1.GetServerRequest,
@ -109,22 +107,21 @@ public final class ChannelzGrpc {
if ((getGetServerMethod = ChannelzGrpc.getGetServerMethod) == null) { if ((getGetServerMethod = ChannelzGrpc.getGetServerMethod) == null) {
synchronized (ChannelzGrpc.class) { synchronized (ChannelzGrpc.class) {
if ((getGetServerMethod = ChannelzGrpc.getGetServerMethod) == null) { if ((getGetServerMethod = ChannelzGrpc.getGetServerMethod) == null) {
ChannelzGrpc.getGetServerMethod = getGetServerMethod = ChannelzGrpc.getGetServerMethod = getGetServerMethod =
io.grpc.MethodDescriptor.<io.grpc.channelz.v1.GetServerRequest, io.grpc.channelz.v1.GetServerResponse>newBuilder() io.grpc.MethodDescriptor.<io.grpc.channelz.v1.GetServerRequest, io.grpc.channelz.v1.GetServerResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.UNARY) .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(SERVICE_NAME, "GetServer"))
"grpc.channelz.v1.Channelz", "GetServer"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.channelz.v1.GetServerRequest.getDefaultInstance())) io.grpc.channelz.v1.GetServerRequest.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.channelz.v1.GetServerResponse.getDefaultInstance())) io.grpc.channelz.v1.GetServerResponse.getDefaultInstance()))
.setSchemaDescriptor(new ChannelzMethodDescriptorSupplier("GetServer")) .setSchemaDescriptor(new ChannelzMethodDescriptorSupplier("GetServer"))
.build(); .build();
}
} }
} }
return getGetServerMethod; }
return getGetServerMethod;
} }
private static volatile io.grpc.MethodDescriptor<io.grpc.channelz.v1.GetServerSocketsRequest, private static volatile io.grpc.MethodDescriptor<io.grpc.channelz.v1.GetServerSocketsRequest,
@ -141,22 +138,21 @@ public final class ChannelzGrpc {
if ((getGetServerSocketsMethod = ChannelzGrpc.getGetServerSocketsMethod) == null) { if ((getGetServerSocketsMethod = ChannelzGrpc.getGetServerSocketsMethod) == null) {
synchronized (ChannelzGrpc.class) { synchronized (ChannelzGrpc.class) {
if ((getGetServerSocketsMethod = ChannelzGrpc.getGetServerSocketsMethod) == null) { if ((getGetServerSocketsMethod = ChannelzGrpc.getGetServerSocketsMethod) == null) {
ChannelzGrpc.getGetServerSocketsMethod = getGetServerSocketsMethod = ChannelzGrpc.getGetServerSocketsMethod = getGetServerSocketsMethod =
io.grpc.MethodDescriptor.<io.grpc.channelz.v1.GetServerSocketsRequest, io.grpc.channelz.v1.GetServerSocketsResponse>newBuilder() io.grpc.MethodDescriptor.<io.grpc.channelz.v1.GetServerSocketsRequest, io.grpc.channelz.v1.GetServerSocketsResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.UNARY) .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(SERVICE_NAME, "GetServerSockets"))
"grpc.channelz.v1.Channelz", "GetServerSockets"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.channelz.v1.GetServerSocketsRequest.getDefaultInstance())) io.grpc.channelz.v1.GetServerSocketsRequest.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.channelz.v1.GetServerSocketsResponse.getDefaultInstance())) io.grpc.channelz.v1.GetServerSocketsResponse.getDefaultInstance()))
.setSchemaDescriptor(new ChannelzMethodDescriptorSupplier("GetServerSockets")) .setSchemaDescriptor(new ChannelzMethodDescriptorSupplier("GetServerSockets"))
.build(); .build();
}
} }
} }
return getGetServerSocketsMethod; }
return getGetServerSocketsMethod;
} }
private static volatile io.grpc.MethodDescriptor<io.grpc.channelz.v1.GetChannelRequest, private static volatile io.grpc.MethodDescriptor<io.grpc.channelz.v1.GetChannelRequest,
@ -173,22 +169,21 @@ public final class ChannelzGrpc {
if ((getGetChannelMethod = ChannelzGrpc.getGetChannelMethod) == null) { if ((getGetChannelMethod = ChannelzGrpc.getGetChannelMethod) == null) {
synchronized (ChannelzGrpc.class) { synchronized (ChannelzGrpc.class) {
if ((getGetChannelMethod = ChannelzGrpc.getGetChannelMethod) == null) { if ((getGetChannelMethod = ChannelzGrpc.getGetChannelMethod) == null) {
ChannelzGrpc.getGetChannelMethod = getGetChannelMethod = ChannelzGrpc.getGetChannelMethod = getGetChannelMethod =
io.grpc.MethodDescriptor.<io.grpc.channelz.v1.GetChannelRequest, io.grpc.channelz.v1.GetChannelResponse>newBuilder() io.grpc.MethodDescriptor.<io.grpc.channelz.v1.GetChannelRequest, io.grpc.channelz.v1.GetChannelResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.UNARY) .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(SERVICE_NAME, "GetChannel"))
"grpc.channelz.v1.Channelz", "GetChannel"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.channelz.v1.GetChannelRequest.getDefaultInstance())) io.grpc.channelz.v1.GetChannelRequest.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.channelz.v1.GetChannelResponse.getDefaultInstance())) io.grpc.channelz.v1.GetChannelResponse.getDefaultInstance()))
.setSchemaDescriptor(new ChannelzMethodDescriptorSupplier("GetChannel")) .setSchemaDescriptor(new ChannelzMethodDescriptorSupplier("GetChannel"))
.build(); .build();
}
} }
} }
return getGetChannelMethod; }
return getGetChannelMethod;
} }
private static volatile io.grpc.MethodDescriptor<io.grpc.channelz.v1.GetSubchannelRequest, private static volatile io.grpc.MethodDescriptor<io.grpc.channelz.v1.GetSubchannelRequest,
@ -205,22 +200,21 @@ public final class ChannelzGrpc {
if ((getGetSubchannelMethod = ChannelzGrpc.getGetSubchannelMethod) == null) { if ((getGetSubchannelMethod = ChannelzGrpc.getGetSubchannelMethod) == null) {
synchronized (ChannelzGrpc.class) { synchronized (ChannelzGrpc.class) {
if ((getGetSubchannelMethod = ChannelzGrpc.getGetSubchannelMethod) == null) { if ((getGetSubchannelMethod = ChannelzGrpc.getGetSubchannelMethod) == null) {
ChannelzGrpc.getGetSubchannelMethod = getGetSubchannelMethod = ChannelzGrpc.getGetSubchannelMethod = getGetSubchannelMethod =
io.grpc.MethodDescriptor.<io.grpc.channelz.v1.GetSubchannelRequest, io.grpc.channelz.v1.GetSubchannelResponse>newBuilder() io.grpc.MethodDescriptor.<io.grpc.channelz.v1.GetSubchannelRequest, io.grpc.channelz.v1.GetSubchannelResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.UNARY) .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(SERVICE_NAME, "GetSubchannel"))
"grpc.channelz.v1.Channelz", "GetSubchannel"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.channelz.v1.GetSubchannelRequest.getDefaultInstance())) io.grpc.channelz.v1.GetSubchannelRequest.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.channelz.v1.GetSubchannelResponse.getDefaultInstance())) io.grpc.channelz.v1.GetSubchannelResponse.getDefaultInstance()))
.setSchemaDescriptor(new ChannelzMethodDescriptorSupplier("GetSubchannel")) .setSchemaDescriptor(new ChannelzMethodDescriptorSupplier("GetSubchannel"))
.build(); .build();
}
} }
} }
return getGetSubchannelMethod; }
return getGetSubchannelMethod;
} }
private static volatile io.grpc.MethodDescriptor<io.grpc.channelz.v1.GetSocketRequest, private static volatile io.grpc.MethodDescriptor<io.grpc.channelz.v1.GetSocketRequest,
@ -237,22 +231,21 @@ public final class ChannelzGrpc {
if ((getGetSocketMethod = ChannelzGrpc.getGetSocketMethod) == null) { if ((getGetSocketMethod = ChannelzGrpc.getGetSocketMethod) == null) {
synchronized (ChannelzGrpc.class) { synchronized (ChannelzGrpc.class) {
if ((getGetSocketMethod = ChannelzGrpc.getGetSocketMethod) == null) { if ((getGetSocketMethod = ChannelzGrpc.getGetSocketMethod) == null) {
ChannelzGrpc.getGetSocketMethod = getGetSocketMethod = ChannelzGrpc.getGetSocketMethod = getGetSocketMethod =
io.grpc.MethodDescriptor.<io.grpc.channelz.v1.GetSocketRequest, io.grpc.channelz.v1.GetSocketResponse>newBuilder() io.grpc.MethodDescriptor.<io.grpc.channelz.v1.GetSocketRequest, io.grpc.channelz.v1.GetSocketResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.UNARY) .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(SERVICE_NAME, "GetSocket"))
"grpc.channelz.v1.Channelz", "GetSocket"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.channelz.v1.GetSocketRequest.getDefaultInstance())) io.grpc.channelz.v1.GetSocketRequest.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.channelz.v1.GetSocketResponse.getDefaultInstance())) io.grpc.channelz.v1.GetSocketResponse.getDefaultInstance()))
.setSchemaDescriptor(new ChannelzMethodDescriptorSupplier("GetSocket")) .setSchemaDescriptor(new ChannelzMethodDescriptorSupplier("GetSocket"))
.build(); .build();
}
} }
} }
return getGetSocketMethod; }
return getGetSocketMethod;
} }
/** /**

View File

@ -41,22 +41,21 @@ public final class HealthGrpc {
if ((getCheckMethod = HealthGrpc.getCheckMethod) == null) { if ((getCheckMethod = HealthGrpc.getCheckMethod) == null) {
synchronized (HealthGrpc.class) { synchronized (HealthGrpc.class) {
if ((getCheckMethod = HealthGrpc.getCheckMethod) == null) { if ((getCheckMethod = HealthGrpc.getCheckMethod) == null) {
HealthGrpc.getCheckMethod = getCheckMethod = HealthGrpc.getCheckMethod = getCheckMethod =
io.grpc.MethodDescriptor.<io.grpc.health.v1.HealthCheckRequest, io.grpc.health.v1.HealthCheckResponse>newBuilder() io.grpc.MethodDescriptor.<io.grpc.health.v1.HealthCheckRequest, io.grpc.health.v1.HealthCheckResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.UNARY) .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(SERVICE_NAME, "Check"))
"grpc.health.v1.Health", "Check"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.health.v1.HealthCheckRequest.getDefaultInstance())) io.grpc.health.v1.HealthCheckRequest.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.health.v1.HealthCheckResponse.getDefaultInstance())) io.grpc.health.v1.HealthCheckResponse.getDefaultInstance()))
.setSchemaDescriptor(new HealthMethodDescriptorSupplier("Check")) .setSchemaDescriptor(new HealthMethodDescriptorSupplier("Check"))
.build(); .build();
}
} }
} }
return getCheckMethod; }
return getCheckMethod;
} }
private static volatile io.grpc.MethodDescriptor<io.grpc.health.v1.HealthCheckRequest, private static volatile io.grpc.MethodDescriptor<io.grpc.health.v1.HealthCheckRequest,
@ -73,22 +72,21 @@ public final class HealthGrpc {
if ((getWatchMethod = HealthGrpc.getWatchMethod) == null) { if ((getWatchMethod = HealthGrpc.getWatchMethod) == null) {
synchronized (HealthGrpc.class) { synchronized (HealthGrpc.class) {
if ((getWatchMethod = HealthGrpc.getWatchMethod) == null) { if ((getWatchMethod = HealthGrpc.getWatchMethod) == null) {
HealthGrpc.getWatchMethod = getWatchMethod = HealthGrpc.getWatchMethod = getWatchMethod =
io.grpc.MethodDescriptor.<io.grpc.health.v1.HealthCheckRequest, io.grpc.health.v1.HealthCheckResponse>newBuilder() io.grpc.MethodDescriptor.<io.grpc.health.v1.HealthCheckRequest, io.grpc.health.v1.HealthCheckResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING) .setType(io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(SERVICE_NAME, "Watch"))
"grpc.health.v1.Health", "Watch"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.health.v1.HealthCheckRequest.getDefaultInstance())) io.grpc.health.v1.HealthCheckRequest.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.health.v1.HealthCheckResponse.getDefaultInstance())) io.grpc.health.v1.HealthCheckResponse.getDefaultInstance()))
.setSchemaDescriptor(new HealthMethodDescriptorSupplier("Watch")) .setSchemaDescriptor(new HealthMethodDescriptorSupplier("Watch"))
.build(); .build();
}
} }
} }
return getWatchMethod; }
return getWatchMethod;
} }
/** /**

View File

@ -41,22 +41,21 @@ public final class ServerReflectionGrpc {
if ((getServerReflectionInfoMethod = ServerReflectionGrpc.getServerReflectionInfoMethod) == null) { if ((getServerReflectionInfoMethod = ServerReflectionGrpc.getServerReflectionInfoMethod) == null) {
synchronized (ServerReflectionGrpc.class) { synchronized (ServerReflectionGrpc.class) {
if ((getServerReflectionInfoMethod = ServerReflectionGrpc.getServerReflectionInfoMethod) == null) { if ((getServerReflectionInfoMethod = ServerReflectionGrpc.getServerReflectionInfoMethod) == null) {
ServerReflectionGrpc.getServerReflectionInfoMethod = getServerReflectionInfoMethod = ServerReflectionGrpc.getServerReflectionInfoMethod = getServerReflectionInfoMethod =
io.grpc.MethodDescriptor.<io.grpc.reflection.v1alpha.ServerReflectionRequest, io.grpc.reflection.v1alpha.ServerReflectionResponse>newBuilder() io.grpc.MethodDescriptor.<io.grpc.reflection.v1alpha.ServerReflectionRequest, io.grpc.reflection.v1alpha.ServerReflectionResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING) .setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(SERVICE_NAME, "ServerReflectionInfo"))
"grpc.reflection.v1alpha.ServerReflection", "ServerReflectionInfo"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.reflection.v1alpha.ServerReflectionRequest.getDefaultInstance())) io.grpc.reflection.v1alpha.ServerReflectionRequest.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.reflection.v1alpha.ServerReflectionResponse.getDefaultInstance())) io.grpc.reflection.v1alpha.ServerReflectionResponse.getDefaultInstance()))
.setSchemaDescriptor(new ServerReflectionMethodDescriptorSupplier("ServerReflectionInfo")) .setSchemaDescriptor(new ServerReflectionMethodDescriptorSupplier("ServerReflectionInfo"))
.build(); .build();
}
} }
} }
return getServerReflectionInfoMethod; }
return getServerReflectionInfoMethod;
} }
/** /**

View File

@ -44,22 +44,21 @@ public final class AnotherDynamicServiceGrpc {
if ((getMethodMethod = AnotherDynamicServiceGrpc.getMethodMethod) == null) { if ((getMethodMethod = AnotherDynamicServiceGrpc.getMethodMethod) == null) {
synchronized (AnotherDynamicServiceGrpc.class) { synchronized (AnotherDynamicServiceGrpc.class) {
if ((getMethodMethod = AnotherDynamicServiceGrpc.getMethodMethod) == null) { if ((getMethodMethod = AnotherDynamicServiceGrpc.getMethodMethod) == null) {
AnotherDynamicServiceGrpc.getMethodMethod = getMethodMethod = AnotherDynamicServiceGrpc.getMethodMethod = getMethodMethod =
io.grpc.MethodDescriptor.<io.grpc.reflection.testing.DynamicRequest, io.grpc.reflection.testing.DynamicReply>newBuilder() io.grpc.MethodDescriptor.<io.grpc.reflection.testing.DynamicRequest, io.grpc.reflection.testing.DynamicReply>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.UNARY) .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(SERVICE_NAME, "Method"))
"grpc.reflection.testing.AnotherDynamicService", "Method"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.reflection.testing.DynamicRequest.getDefaultInstance())) io.grpc.reflection.testing.DynamicRequest.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.reflection.testing.DynamicReply.getDefaultInstance())) io.grpc.reflection.testing.DynamicReply.getDefaultInstance()))
.setSchemaDescriptor(new AnotherDynamicServiceMethodDescriptorSupplier("Method")) .setSchemaDescriptor(new AnotherDynamicServiceMethodDescriptorSupplier("Method"))
.build(); .build();
}
} }
} }
return getMethodMethod; }
return getMethodMethod;
} }
/** /**

View File

@ -44,22 +44,21 @@ public final class DynamicServiceGrpc {
if ((getMethodMethod = DynamicServiceGrpc.getMethodMethod) == null) { if ((getMethodMethod = DynamicServiceGrpc.getMethodMethod) == null) {
synchronized (DynamicServiceGrpc.class) { synchronized (DynamicServiceGrpc.class) {
if ((getMethodMethod = DynamicServiceGrpc.getMethodMethod) == null) { if ((getMethodMethod = DynamicServiceGrpc.getMethodMethod) == null) {
DynamicServiceGrpc.getMethodMethod = getMethodMethod = DynamicServiceGrpc.getMethodMethod = getMethodMethod =
io.grpc.MethodDescriptor.<io.grpc.reflection.testing.DynamicRequest, io.grpc.reflection.testing.DynamicReply>newBuilder() io.grpc.MethodDescriptor.<io.grpc.reflection.testing.DynamicRequest, io.grpc.reflection.testing.DynamicReply>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.UNARY) .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(SERVICE_NAME, "Method"))
"grpc.reflection.testing.DynamicService", "Method"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.reflection.testing.DynamicRequest.getDefaultInstance())) io.grpc.reflection.testing.DynamicRequest.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.reflection.testing.DynamicReply.getDefaultInstance())) io.grpc.reflection.testing.DynamicReply.getDefaultInstance()))
.setSchemaDescriptor(new DynamicServiceMethodDescriptorSupplier("Method")) .setSchemaDescriptor(new DynamicServiceMethodDescriptorSupplier("Method"))
.build(); .build();
}
} }
} }
return getMethodMethod; }
return getMethodMethod;
} }
/** /**

View File

@ -41,22 +41,21 @@ public final class ReflectableServiceGrpc {
if ((getMethodMethod = ReflectableServiceGrpc.getMethodMethod) == null) { if ((getMethodMethod = ReflectableServiceGrpc.getMethodMethod) == null) {
synchronized (ReflectableServiceGrpc.class) { synchronized (ReflectableServiceGrpc.class) {
if ((getMethodMethod = ReflectableServiceGrpc.getMethodMethod) == null) { if ((getMethodMethod = ReflectableServiceGrpc.getMethodMethod) == null) {
ReflectableServiceGrpc.getMethodMethod = getMethodMethod = ReflectableServiceGrpc.getMethodMethod = getMethodMethod =
io.grpc.MethodDescriptor.<io.grpc.reflection.testing.Request, io.grpc.reflection.testing.Reply>newBuilder() io.grpc.MethodDescriptor.<io.grpc.reflection.testing.Request, io.grpc.reflection.testing.Reply>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.UNARY) .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(SERVICE_NAME, "Method"))
"grpc.reflection.testing.ReflectableService", "Method"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.reflection.testing.Request.getDefaultInstance())) io.grpc.reflection.testing.Request.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.reflection.testing.Reply.getDefaultInstance())) io.grpc.reflection.testing.Reply.getDefaultInstance()))
.setSchemaDescriptor(new ReflectableServiceMethodDescriptorSupplier("Method")) .setSchemaDescriptor(new ReflectableServiceMethodDescriptorSupplier("Method"))
.build(); .build();
}
} }
} }
return getMethodMethod; }
return getMethodMethod;
} }
/** /**

View File

@ -44,22 +44,21 @@ public final class SimpleServiceGrpc {
if ((getUnaryRpcMethod = SimpleServiceGrpc.getUnaryRpcMethod) == null) { if ((getUnaryRpcMethod = SimpleServiceGrpc.getUnaryRpcMethod) == null) {
synchronized (SimpleServiceGrpc.class) { synchronized (SimpleServiceGrpc.class) {
if ((getUnaryRpcMethod = SimpleServiceGrpc.getUnaryRpcMethod) == null) { if ((getUnaryRpcMethod = SimpleServiceGrpc.getUnaryRpcMethod) == null) {
SimpleServiceGrpc.getUnaryRpcMethod = getUnaryRpcMethod = SimpleServiceGrpc.getUnaryRpcMethod = getUnaryRpcMethod =
io.grpc.MethodDescriptor.<io.grpc.testing.protobuf.SimpleRequest, io.grpc.testing.protobuf.SimpleResponse>newBuilder() io.grpc.MethodDescriptor.<io.grpc.testing.protobuf.SimpleRequest, io.grpc.testing.protobuf.SimpleResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.UNARY) .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(SERVICE_NAME, "UnaryRpc"))
"grpc.testing.SimpleService", "UnaryRpc"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.testing.protobuf.SimpleRequest.getDefaultInstance())) io.grpc.testing.protobuf.SimpleRequest.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.testing.protobuf.SimpleResponse.getDefaultInstance())) io.grpc.testing.protobuf.SimpleResponse.getDefaultInstance()))
.setSchemaDescriptor(new SimpleServiceMethodDescriptorSupplier("UnaryRpc")) .setSchemaDescriptor(new SimpleServiceMethodDescriptorSupplier("UnaryRpc"))
.build(); .build();
}
} }
} }
return getUnaryRpcMethod; }
return getUnaryRpcMethod;
} }
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.protobuf.SimpleRequest, private static volatile io.grpc.MethodDescriptor<io.grpc.testing.protobuf.SimpleRequest,
@ -76,22 +75,21 @@ public final class SimpleServiceGrpc {
if ((getClientStreamingRpcMethod = SimpleServiceGrpc.getClientStreamingRpcMethod) == null) { if ((getClientStreamingRpcMethod = SimpleServiceGrpc.getClientStreamingRpcMethod) == null) {
synchronized (SimpleServiceGrpc.class) { synchronized (SimpleServiceGrpc.class) {
if ((getClientStreamingRpcMethod = SimpleServiceGrpc.getClientStreamingRpcMethod) == null) { if ((getClientStreamingRpcMethod = SimpleServiceGrpc.getClientStreamingRpcMethod) == null) {
SimpleServiceGrpc.getClientStreamingRpcMethod = getClientStreamingRpcMethod = SimpleServiceGrpc.getClientStreamingRpcMethod = getClientStreamingRpcMethod =
io.grpc.MethodDescriptor.<io.grpc.testing.protobuf.SimpleRequest, io.grpc.testing.protobuf.SimpleResponse>newBuilder() io.grpc.MethodDescriptor.<io.grpc.testing.protobuf.SimpleRequest, io.grpc.testing.protobuf.SimpleResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.CLIENT_STREAMING) .setType(io.grpc.MethodDescriptor.MethodType.CLIENT_STREAMING)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(SERVICE_NAME, "ClientStreamingRpc"))
"grpc.testing.SimpleService", "ClientStreamingRpc"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.testing.protobuf.SimpleRequest.getDefaultInstance())) io.grpc.testing.protobuf.SimpleRequest.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.testing.protobuf.SimpleResponse.getDefaultInstance())) io.grpc.testing.protobuf.SimpleResponse.getDefaultInstance()))
.setSchemaDescriptor(new SimpleServiceMethodDescriptorSupplier("ClientStreamingRpc")) .setSchemaDescriptor(new SimpleServiceMethodDescriptorSupplier("ClientStreamingRpc"))
.build(); .build();
}
} }
} }
return getClientStreamingRpcMethod; }
return getClientStreamingRpcMethod;
} }
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.protobuf.SimpleRequest, private static volatile io.grpc.MethodDescriptor<io.grpc.testing.protobuf.SimpleRequest,
@ -108,22 +106,21 @@ public final class SimpleServiceGrpc {
if ((getServerStreamingRpcMethod = SimpleServiceGrpc.getServerStreamingRpcMethod) == null) { if ((getServerStreamingRpcMethod = SimpleServiceGrpc.getServerStreamingRpcMethod) == null) {
synchronized (SimpleServiceGrpc.class) { synchronized (SimpleServiceGrpc.class) {
if ((getServerStreamingRpcMethod = SimpleServiceGrpc.getServerStreamingRpcMethod) == null) { if ((getServerStreamingRpcMethod = SimpleServiceGrpc.getServerStreamingRpcMethod) == null) {
SimpleServiceGrpc.getServerStreamingRpcMethod = getServerStreamingRpcMethod = SimpleServiceGrpc.getServerStreamingRpcMethod = getServerStreamingRpcMethod =
io.grpc.MethodDescriptor.<io.grpc.testing.protobuf.SimpleRequest, io.grpc.testing.protobuf.SimpleResponse>newBuilder() io.grpc.MethodDescriptor.<io.grpc.testing.protobuf.SimpleRequest, io.grpc.testing.protobuf.SimpleResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING) .setType(io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(SERVICE_NAME, "ServerStreamingRpc"))
"grpc.testing.SimpleService", "ServerStreamingRpc"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.testing.protobuf.SimpleRequest.getDefaultInstance())) io.grpc.testing.protobuf.SimpleRequest.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.testing.protobuf.SimpleResponse.getDefaultInstance())) io.grpc.testing.protobuf.SimpleResponse.getDefaultInstance()))
.setSchemaDescriptor(new SimpleServiceMethodDescriptorSupplier("ServerStreamingRpc")) .setSchemaDescriptor(new SimpleServiceMethodDescriptorSupplier("ServerStreamingRpc"))
.build(); .build();
}
} }
} }
return getServerStreamingRpcMethod; }
return getServerStreamingRpcMethod;
} }
private static volatile io.grpc.MethodDescriptor<io.grpc.testing.protobuf.SimpleRequest, private static volatile io.grpc.MethodDescriptor<io.grpc.testing.protobuf.SimpleRequest,
@ -140,22 +137,21 @@ public final class SimpleServiceGrpc {
if ((getBidiStreamingRpcMethod = SimpleServiceGrpc.getBidiStreamingRpcMethod) == null) { if ((getBidiStreamingRpcMethod = SimpleServiceGrpc.getBidiStreamingRpcMethod) == null) {
synchronized (SimpleServiceGrpc.class) { synchronized (SimpleServiceGrpc.class) {
if ((getBidiStreamingRpcMethod = SimpleServiceGrpc.getBidiStreamingRpcMethod) == null) { if ((getBidiStreamingRpcMethod = SimpleServiceGrpc.getBidiStreamingRpcMethod) == null) {
SimpleServiceGrpc.getBidiStreamingRpcMethod = getBidiStreamingRpcMethod = SimpleServiceGrpc.getBidiStreamingRpcMethod = getBidiStreamingRpcMethod =
io.grpc.MethodDescriptor.<io.grpc.testing.protobuf.SimpleRequest, io.grpc.testing.protobuf.SimpleResponse>newBuilder() io.grpc.MethodDescriptor.<io.grpc.testing.protobuf.SimpleRequest, io.grpc.testing.protobuf.SimpleResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING) .setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(SERVICE_NAME, "BidiStreamingRpc"))
"grpc.testing.SimpleService", "BidiStreamingRpc"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.testing.protobuf.SimpleRequest.getDefaultInstance())) io.grpc.testing.protobuf.SimpleRequest.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.grpc.testing.protobuf.SimpleResponse.getDefaultInstance())) io.grpc.testing.protobuf.SimpleResponse.getDefaultInstance()))
.setSchemaDescriptor(new SimpleServiceMethodDescriptorSupplier("BidiStreamingRpc")) .setSchemaDescriptor(new SimpleServiceMethodDescriptorSupplier("BidiStreamingRpc"))
.build(); .build();
}
} }
} }
return getBidiStreamingRpcMethod; }
return getBidiStreamingRpcMethod;
} }
/** /**

View File

@ -44,22 +44,21 @@ public final class ClusterDiscoveryServiceGrpc {
if ((getStreamClustersMethod = ClusterDiscoveryServiceGrpc.getStreamClustersMethod) == null) { if ((getStreamClustersMethod = ClusterDiscoveryServiceGrpc.getStreamClustersMethod) == null) {
synchronized (ClusterDiscoveryServiceGrpc.class) { synchronized (ClusterDiscoveryServiceGrpc.class) {
if ((getStreamClustersMethod = ClusterDiscoveryServiceGrpc.getStreamClustersMethod) == null) { if ((getStreamClustersMethod = ClusterDiscoveryServiceGrpc.getStreamClustersMethod) == null) {
ClusterDiscoveryServiceGrpc.getStreamClustersMethod = getStreamClustersMethod = ClusterDiscoveryServiceGrpc.getStreamClustersMethod = getStreamClustersMethod =
io.grpc.MethodDescriptor.<io.envoyproxy.envoy.api.v2.DiscoveryRequest, io.envoyproxy.envoy.api.v2.DiscoveryResponse>newBuilder() io.grpc.MethodDescriptor.<io.envoyproxy.envoy.api.v2.DiscoveryRequest, io.envoyproxy.envoy.api.v2.DiscoveryResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING) .setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(SERVICE_NAME, "StreamClusters"))
"envoy.api.v2.ClusterDiscoveryService", "StreamClusters"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.envoyproxy.envoy.api.v2.DiscoveryRequest.getDefaultInstance())) io.envoyproxy.envoy.api.v2.DiscoveryRequest.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.envoyproxy.envoy.api.v2.DiscoveryResponse.getDefaultInstance())) io.envoyproxy.envoy.api.v2.DiscoveryResponse.getDefaultInstance()))
.setSchemaDescriptor(new ClusterDiscoveryServiceMethodDescriptorSupplier("StreamClusters")) .setSchemaDescriptor(new ClusterDiscoveryServiceMethodDescriptorSupplier("StreamClusters"))
.build(); .build();
}
} }
} }
return getStreamClustersMethod; }
return getStreamClustersMethod;
} }
private static volatile io.grpc.MethodDescriptor<io.envoyproxy.envoy.api.v2.DeltaDiscoveryRequest, private static volatile io.grpc.MethodDescriptor<io.envoyproxy.envoy.api.v2.DeltaDiscoveryRequest,
@ -76,22 +75,21 @@ public final class ClusterDiscoveryServiceGrpc {
if ((getDeltaClustersMethod = ClusterDiscoveryServiceGrpc.getDeltaClustersMethod) == null) { if ((getDeltaClustersMethod = ClusterDiscoveryServiceGrpc.getDeltaClustersMethod) == null) {
synchronized (ClusterDiscoveryServiceGrpc.class) { synchronized (ClusterDiscoveryServiceGrpc.class) {
if ((getDeltaClustersMethod = ClusterDiscoveryServiceGrpc.getDeltaClustersMethod) == null) { if ((getDeltaClustersMethod = ClusterDiscoveryServiceGrpc.getDeltaClustersMethod) == null) {
ClusterDiscoveryServiceGrpc.getDeltaClustersMethod = getDeltaClustersMethod = ClusterDiscoveryServiceGrpc.getDeltaClustersMethod = getDeltaClustersMethod =
io.grpc.MethodDescriptor.<io.envoyproxy.envoy.api.v2.DeltaDiscoveryRequest, io.envoyproxy.envoy.api.v2.DeltaDiscoveryResponse>newBuilder() io.grpc.MethodDescriptor.<io.envoyproxy.envoy.api.v2.DeltaDiscoveryRequest, io.envoyproxy.envoy.api.v2.DeltaDiscoveryResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING) .setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(SERVICE_NAME, "DeltaClusters"))
"envoy.api.v2.ClusterDiscoveryService", "DeltaClusters"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.envoyproxy.envoy.api.v2.DeltaDiscoveryRequest.getDefaultInstance())) io.envoyproxy.envoy.api.v2.DeltaDiscoveryRequest.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.envoyproxy.envoy.api.v2.DeltaDiscoveryResponse.getDefaultInstance())) io.envoyproxy.envoy.api.v2.DeltaDiscoveryResponse.getDefaultInstance()))
.setSchemaDescriptor(new ClusterDiscoveryServiceMethodDescriptorSupplier("DeltaClusters")) .setSchemaDescriptor(new ClusterDiscoveryServiceMethodDescriptorSupplier("DeltaClusters"))
.build(); .build();
}
} }
} }
return getDeltaClustersMethod; }
return getDeltaClustersMethod;
} }
private static volatile io.grpc.MethodDescriptor<io.envoyproxy.envoy.api.v2.DiscoveryRequest, private static volatile io.grpc.MethodDescriptor<io.envoyproxy.envoy.api.v2.DiscoveryRequest,
@ -108,22 +106,21 @@ public final class ClusterDiscoveryServiceGrpc {
if ((getFetchClustersMethod = ClusterDiscoveryServiceGrpc.getFetchClustersMethod) == null) { if ((getFetchClustersMethod = ClusterDiscoveryServiceGrpc.getFetchClustersMethod) == null) {
synchronized (ClusterDiscoveryServiceGrpc.class) { synchronized (ClusterDiscoveryServiceGrpc.class) {
if ((getFetchClustersMethod = ClusterDiscoveryServiceGrpc.getFetchClustersMethod) == null) { if ((getFetchClustersMethod = ClusterDiscoveryServiceGrpc.getFetchClustersMethod) == null) {
ClusterDiscoveryServiceGrpc.getFetchClustersMethod = getFetchClustersMethod = ClusterDiscoveryServiceGrpc.getFetchClustersMethod = getFetchClustersMethod =
io.grpc.MethodDescriptor.<io.envoyproxy.envoy.api.v2.DiscoveryRequest, io.envoyproxy.envoy.api.v2.DiscoveryResponse>newBuilder() io.grpc.MethodDescriptor.<io.envoyproxy.envoy.api.v2.DiscoveryRequest, io.envoyproxy.envoy.api.v2.DiscoveryResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.UNARY) .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(SERVICE_NAME, "FetchClusters"))
"envoy.api.v2.ClusterDiscoveryService", "FetchClusters"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.envoyproxy.envoy.api.v2.DiscoveryRequest.getDefaultInstance())) io.envoyproxy.envoy.api.v2.DiscoveryRequest.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.envoyproxy.envoy.api.v2.DiscoveryResponse.getDefaultInstance())) io.envoyproxy.envoy.api.v2.DiscoveryResponse.getDefaultInstance()))
.setSchemaDescriptor(new ClusterDiscoveryServiceMethodDescriptorSupplier("FetchClusters")) .setSchemaDescriptor(new ClusterDiscoveryServiceMethodDescriptorSupplier("FetchClusters"))
.build(); .build();
}
} }
} }
return getFetchClustersMethod; }
return getFetchClustersMethod;
} }
/** /**

View File

@ -41,22 +41,21 @@ public final class EndpointDiscoveryServiceGrpc {
if ((getStreamEndpointsMethod = EndpointDiscoveryServiceGrpc.getStreamEndpointsMethod) == null) { if ((getStreamEndpointsMethod = EndpointDiscoveryServiceGrpc.getStreamEndpointsMethod) == null) {
synchronized (EndpointDiscoveryServiceGrpc.class) { synchronized (EndpointDiscoveryServiceGrpc.class) {
if ((getStreamEndpointsMethod = EndpointDiscoveryServiceGrpc.getStreamEndpointsMethod) == null) { if ((getStreamEndpointsMethod = EndpointDiscoveryServiceGrpc.getStreamEndpointsMethod) == null) {
EndpointDiscoveryServiceGrpc.getStreamEndpointsMethod = getStreamEndpointsMethod = EndpointDiscoveryServiceGrpc.getStreamEndpointsMethod = getStreamEndpointsMethod =
io.grpc.MethodDescriptor.<io.envoyproxy.envoy.api.v2.DiscoveryRequest, io.envoyproxy.envoy.api.v2.DiscoveryResponse>newBuilder() io.grpc.MethodDescriptor.<io.envoyproxy.envoy.api.v2.DiscoveryRequest, io.envoyproxy.envoy.api.v2.DiscoveryResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING) .setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(SERVICE_NAME, "StreamEndpoints"))
"envoy.api.v2.EndpointDiscoveryService", "StreamEndpoints"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.envoyproxy.envoy.api.v2.DiscoveryRequest.getDefaultInstance())) io.envoyproxy.envoy.api.v2.DiscoveryRequest.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.envoyproxy.envoy.api.v2.DiscoveryResponse.getDefaultInstance())) io.envoyproxy.envoy.api.v2.DiscoveryResponse.getDefaultInstance()))
.setSchemaDescriptor(new EndpointDiscoveryServiceMethodDescriptorSupplier("StreamEndpoints")) .setSchemaDescriptor(new EndpointDiscoveryServiceMethodDescriptorSupplier("StreamEndpoints"))
.build(); .build();
}
} }
} }
return getStreamEndpointsMethod; }
return getStreamEndpointsMethod;
} }
private static volatile io.grpc.MethodDescriptor<io.envoyproxy.envoy.api.v2.DeltaDiscoveryRequest, private static volatile io.grpc.MethodDescriptor<io.envoyproxy.envoy.api.v2.DeltaDiscoveryRequest,
@ -73,22 +72,21 @@ public final class EndpointDiscoveryServiceGrpc {
if ((getDeltaEndpointsMethod = EndpointDiscoveryServiceGrpc.getDeltaEndpointsMethod) == null) { if ((getDeltaEndpointsMethod = EndpointDiscoveryServiceGrpc.getDeltaEndpointsMethod) == null) {
synchronized (EndpointDiscoveryServiceGrpc.class) { synchronized (EndpointDiscoveryServiceGrpc.class) {
if ((getDeltaEndpointsMethod = EndpointDiscoveryServiceGrpc.getDeltaEndpointsMethod) == null) { if ((getDeltaEndpointsMethod = EndpointDiscoveryServiceGrpc.getDeltaEndpointsMethod) == null) {
EndpointDiscoveryServiceGrpc.getDeltaEndpointsMethod = getDeltaEndpointsMethod = EndpointDiscoveryServiceGrpc.getDeltaEndpointsMethod = getDeltaEndpointsMethod =
io.grpc.MethodDescriptor.<io.envoyproxy.envoy.api.v2.DeltaDiscoveryRequest, io.envoyproxy.envoy.api.v2.DeltaDiscoveryResponse>newBuilder() io.grpc.MethodDescriptor.<io.envoyproxy.envoy.api.v2.DeltaDiscoveryRequest, io.envoyproxy.envoy.api.v2.DeltaDiscoveryResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING) .setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(SERVICE_NAME, "DeltaEndpoints"))
"envoy.api.v2.EndpointDiscoveryService", "DeltaEndpoints"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.envoyproxy.envoy.api.v2.DeltaDiscoveryRequest.getDefaultInstance())) io.envoyproxy.envoy.api.v2.DeltaDiscoveryRequest.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.envoyproxy.envoy.api.v2.DeltaDiscoveryResponse.getDefaultInstance())) io.envoyproxy.envoy.api.v2.DeltaDiscoveryResponse.getDefaultInstance()))
.setSchemaDescriptor(new EndpointDiscoveryServiceMethodDescriptorSupplier("DeltaEndpoints")) .setSchemaDescriptor(new EndpointDiscoveryServiceMethodDescriptorSupplier("DeltaEndpoints"))
.build(); .build();
}
} }
} }
return getDeltaEndpointsMethod; }
return getDeltaEndpointsMethod;
} }
private static volatile io.grpc.MethodDescriptor<io.envoyproxy.envoy.api.v2.DiscoveryRequest, private static volatile io.grpc.MethodDescriptor<io.envoyproxy.envoy.api.v2.DiscoveryRequest,
@ -105,22 +103,21 @@ public final class EndpointDiscoveryServiceGrpc {
if ((getFetchEndpointsMethod = EndpointDiscoveryServiceGrpc.getFetchEndpointsMethod) == null) { if ((getFetchEndpointsMethod = EndpointDiscoveryServiceGrpc.getFetchEndpointsMethod) == null) {
synchronized (EndpointDiscoveryServiceGrpc.class) { synchronized (EndpointDiscoveryServiceGrpc.class) {
if ((getFetchEndpointsMethod = EndpointDiscoveryServiceGrpc.getFetchEndpointsMethod) == null) { if ((getFetchEndpointsMethod = EndpointDiscoveryServiceGrpc.getFetchEndpointsMethod) == null) {
EndpointDiscoveryServiceGrpc.getFetchEndpointsMethod = getFetchEndpointsMethod = EndpointDiscoveryServiceGrpc.getFetchEndpointsMethod = getFetchEndpointsMethod =
io.grpc.MethodDescriptor.<io.envoyproxy.envoy.api.v2.DiscoveryRequest, io.envoyproxy.envoy.api.v2.DiscoveryResponse>newBuilder() io.grpc.MethodDescriptor.<io.envoyproxy.envoy.api.v2.DiscoveryRequest, io.envoyproxy.envoy.api.v2.DiscoveryResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.UNARY) .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(SERVICE_NAME, "FetchEndpoints"))
"envoy.api.v2.EndpointDiscoveryService", "FetchEndpoints"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.envoyproxy.envoy.api.v2.DiscoveryRequest.getDefaultInstance())) io.envoyproxy.envoy.api.v2.DiscoveryRequest.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.envoyproxy.envoy.api.v2.DiscoveryResponse.getDefaultInstance())) io.envoyproxy.envoy.api.v2.DiscoveryResponse.getDefaultInstance()))
.setSchemaDescriptor(new EndpointDiscoveryServiceMethodDescriptorSupplier("FetchEndpoints")) .setSchemaDescriptor(new EndpointDiscoveryServiceMethodDescriptorSupplier("FetchEndpoints"))
.build(); .build();
}
} }
} }
return getFetchEndpointsMethod; }
return getFetchEndpointsMethod;
} }
/** /**

View File

@ -49,22 +49,21 @@ public final class AggregatedDiscoveryServiceGrpc {
if ((getStreamAggregatedResourcesMethod = AggregatedDiscoveryServiceGrpc.getStreamAggregatedResourcesMethod) == null) { if ((getStreamAggregatedResourcesMethod = AggregatedDiscoveryServiceGrpc.getStreamAggregatedResourcesMethod) == null) {
synchronized (AggregatedDiscoveryServiceGrpc.class) { synchronized (AggregatedDiscoveryServiceGrpc.class) {
if ((getStreamAggregatedResourcesMethod = AggregatedDiscoveryServiceGrpc.getStreamAggregatedResourcesMethod) == null) { if ((getStreamAggregatedResourcesMethod = AggregatedDiscoveryServiceGrpc.getStreamAggregatedResourcesMethod) == null) {
AggregatedDiscoveryServiceGrpc.getStreamAggregatedResourcesMethod = getStreamAggregatedResourcesMethod = AggregatedDiscoveryServiceGrpc.getStreamAggregatedResourcesMethod = getStreamAggregatedResourcesMethod =
io.grpc.MethodDescriptor.<io.envoyproxy.envoy.api.v2.DiscoveryRequest, io.envoyproxy.envoy.api.v2.DiscoveryResponse>newBuilder() io.grpc.MethodDescriptor.<io.envoyproxy.envoy.api.v2.DiscoveryRequest, io.envoyproxy.envoy.api.v2.DiscoveryResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING) .setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(SERVICE_NAME, "StreamAggregatedResources"))
"envoy.service.discovery.v2.AggregatedDiscoveryService", "StreamAggregatedResources"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.envoyproxy.envoy.api.v2.DiscoveryRequest.getDefaultInstance())) io.envoyproxy.envoy.api.v2.DiscoveryRequest.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.envoyproxy.envoy.api.v2.DiscoveryResponse.getDefaultInstance())) io.envoyproxy.envoy.api.v2.DiscoveryResponse.getDefaultInstance()))
.setSchemaDescriptor(new AggregatedDiscoveryServiceMethodDescriptorSupplier("StreamAggregatedResources")) .setSchemaDescriptor(new AggregatedDiscoveryServiceMethodDescriptorSupplier("StreamAggregatedResources"))
.build(); .build();
}
} }
} }
return getStreamAggregatedResourcesMethod; }
return getStreamAggregatedResourcesMethod;
} }
private static volatile io.grpc.MethodDescriptor<io.envoyproxy.envoy.api.v2.DeltaDiscoveryRequest, private static volatile io.grpc.MethodDescriptor<io.envoyproxy.envoy.api.v2.DeltaDiscoveryRequest,
@ -81,22 +80,21 @@ public final class AggregatedDiscoveryServiceGrpc {
if ((getDeltaAggregatedResourcesMethod = AggregatedDiscoveryServiceGrpc.getDeltaAggregatedResourcesMethod) == null) { if ((getDeltaAggregatedResourcesMethod = AggregatedDiscoveryServiceGrpc.getDeltaAggregatedResourcesMethod) == null) {
synchronized (AggregatedDiscoveryServiceGrpc.class) { synchronized (AggregatedDiscoveryServiceGrpc.class) {
if ((getDeltaAggregatedResourcesMethod = AggregatedDiscoveryServiceGrpc.getDeltaAggregatedResourcesMethod) == null) { if ((getDeltaAggregatedResourcesMethod = AggregatedDiscoveryServiceGrpc.getDeltaAggregatedResourcesMethod) == null) {
AggregatedDiscoveryServiceGrpc.getDeltaAggregatedResourcesMethod = getDeltaAggregatedResourcesMethod = AggregatedDiscoveryServiceGrpc.getDeltaAggregatedResourcesMethod = getDeltaAggregatedResourcesMethod =
io.grpc.MethodDescriptor.<io.envoyproxy.envoy.api.v2.DeltaDiscoveryRequest, io.envoyproxy.envoy.api.v2.DeltaDiscoveryResponse>newBuilder() io.grpc.MethodDescriptor.<io.envoyproxy.envoy.api.v2.DeltaDiscoveryRequest, io.envoyproxy.envoy.api.v2.DeltaDiscoveryResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING) .setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(SERVICE_NAME, "DeltaAggregatedResources"))
"envoy.service.discovery.v2.AggregatedDiscoveryService", "DeltaAggregatedResources"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.envoyproxy.envoy.api.v2.DeltaDiscoveryRequest.getDefaultInstance())) io.envoyproxy.envoy.api.v2.DeltaDiscoveryRequest.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.envoyproxy.envoy.api.v2.DeltaDiscoveryResponse.getDefaultInstance())) io.envoyproxy.envoy.api.v2.DeltaDiscoveryResponse.getDefaultInstance()))
.setSchemaDescriptor(new AggregatedDiscoveryServiceMethodDescriptorSupplier("DeltaAggregatedResources")) .setSchemaDescriptor(new AggregatedDiscoveryServiceMethodDescriptorSupplier("DeltaAggregatedResources"))
.build(); .build();
}
} }
} }
return getDeltaAggregatedResourcesMethod; }
return getDeltaAggregatedResourcesMethod;
} }
/** /**

View File

@ -41,22 +41,21 @@ public final class LoadReportingServiceGrpc {
if ((getStreamLoadStatsMethod = LoadReportingServiceGrpc.getStreamLoadStatsMethod) == null) { if ((getStreamLoadStatsMethod = LoadReportingServiceGrpc.getStreamLoadStatsMethod) == null) {
synchronized (LoadReportingServiceGrpc.class) { synchronized (LoadReportingServiceGrpc.class) {
if ((getStreamLoadStatsMethod = LoadReportingServiceGrpc.getStreamLoadStatsMethod) == null) { if ((getStreamLoadStatsMethod = LoadReportingServiceGrpc.getStreamLoadStatsMethod) == null) {
LoadReportingServiceGrpc.getStreamLoadStatsMethod = getStreamLoadStatsMethod = LoadReportingServiceGrpc.getStreamLoadStatsMethod = getStreamLoadStatsMethod =
io.grpc.MethodDescriptor.<io.envoyproxy.envoy.service.load_stats.v2.LoadStatsRequest, io.envoyproxy.envoy.service.load_stats.v2.LoadStatsResponse>newBuilder() io.grpc.MethodDescriptor.<io.envoyproxy.envoy.service.load_stats.v2.LoadStatsRequest, io.envoyproxy.envoy.service.load_stats.v2.LoadStatsResponse>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING) .setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(SERVICE_NAME, "StreamLoadStats"))
"envoy.service.load_stats.v2.LoadReportingService", "StreamLoadStats"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.envoyproxy.envoy.service.load_stats.v2.LoadStatsRequest.getDefaultInstance())) io.envoyproxy.envoy.service.load_stats.v2.LoadStatsRequest.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.envoyproxy.envoy.service.load_stats.v2.LoadStatsResponse.getDefaultInstance())) io.envoyproxy.envoy.service.load_stats.v2.LoadStatsResponse.getDefaultInstance()))
.setSchemaDescriptor(new LoadReportingServiceMethodDescriptorSupplier("StreamLoadStats")) .setSchemaDescriptor(new LoadReportingServiceMethodDescriptorSupplier("StreamLoadStats"))
.build(); .build();
}
} }
} }
return getStreamLoadStatsMethod; }
return getStreamLoadStatsMethod;
} }
/** /**

View File

@ -51,22 +51,21 @@ public final class OpenRcaServiceGrpc {
if ((getStreamCoreMetricsMethod = OpenRcaServiceGrpc.getStreamCoreMetricsMethod) == null) { if ((getStreamCoreMetricsMethod = OpenRcaServiceGrpc.getStreamCoreMetricsMethod) == null) {
synchronized (OpenRcaServiceGrpc.class) { synchronized (OpenRcaServiceGrpc.class) {
if ((getStreamCoreMetricsMethod = OpenRcaServiceGrpc.getStreamCoreMetricsMethod) == null) { if ((getStreamCoreMetricsMethod = OpenRcaServiceGrpc.getStreamCoreMetricsMethod) == null) {
OpenRcaServiceGrpc.getStreamCoreMetricsMethod = getStreamCoreMetricsMethod = OpenRcaServiceGrpc.getStreamCoreMetricsMethod = getStreamCoreMetricsMethod =
io.grpc.MethodDescriptor.<io.envoyproxy.udpa.service.orca.v1.OrcaLoadReportRequest, io.envoyproxy.udpa.data.orca.v1.OrcaLoadReport>newBuilder() io.grpc.MethodDescriptor.<io.envoyproxy.udpa.service.orca.v1.OrcaLoadReportRequest, io.envoyproxy.udpa.data.orca.v1.OrcaLoadReport>newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING) .setType(io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING)
.setFullMethodName(generateFullMethodName( .setFullMethodName(generateFullMethodName(SERVICE_NAME, "StreamCoreMetrics"))
"udpa.service.orca.v1.OpenRcaService", "StreamCoreMetrics"))
.setSampledToLocalTracing(true) .setSampledToLocalTracing(true)
.setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.envoyproxy.udpa.service.orca.v1.OrcaLoadReportRequest.getDefaultInstance())) io.envoyproxy.udpa.service.orca.v1.OrcaLoadReportRequest.getDefaultInstance()))
.setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
io.envoyproxy.udpa.data.orca.v1.OrcaLoadReport.getDefaultInstance())) io.envoyproxy.udpa.data.orca.v1.OrcaLoadReport.getDefaultInstance()))
.setSchemaDescriptor(new OpenRcaServiceMethodDescriptorSupplier("StreamCoreMetrics")) .setSchemaDescriptor(new OpenRcaServiceMethodDescriptorSupplier("StreamCoreMetrics"))
.build(); .build();
}
} }
} }
return getStreamCoreMetricsMethod; }
return getStreamCoreMetricsMethod;
} }
/** /**