Package com.github.xds.service.orca.v3
Class OpenRcaServiceGrpc.OpenRcaServiceStub
java.lang.Object
io.grpc.stub.AbstractStub<OpenRcaServiceGrpc.OpenRcaServiceStub>
io.grpc.stub.AbstractAsyncStub<OpenRcaServiceGrpc.OpenRcaServiceStub>
com.github.xds.service.orca.v3.OpenRcaServiceGrpc.OpenRcaServiceStub
- Enclosing class:
OpenRcaServiceGrpc
public static final class OpenRcaServiceGrpc.OpenRcaServiceStub
extends io.grpc.stub.AbstractAsyncStub<OpenRcaServiceGrpc.OpenRcaServiceStub>
A stub to allow clients to do asynchronous rpc calls to service OpenRcaService.
Out-of-band (OOB) load reporting service for the additional load reporting agent that does not sit in the request path. Reports are periodically sampled with sufficient frequency to provide temporal association with requests. OOB reporting compensates the limitation of in-band reporting in revealing costs for backends that do not provide a steady stream of telemetry such as long running stream operations and zero QPS services. This is a server streaming service, client needs to terminate current RPC and initiate a new call to change backend reporting frequency.
-
Nested Class Summary
Nested classes/interfaces inherited from class io.grpc.stub.AbstractStub
io.grpc.stub.AbstractStub.StubFactory<T extends io.grpc.stub.AbstractStub<T>>
-
Constructor Summary
ConstructorsModifierConstructorDescriptionprivate
OpenRcaServiceStub
(io.grpc.Channel channel, io.grpc.CallOptions callOptions) -
Method Summary
Modifier and TypeMethodDescriptionprotected OpenRcaServiceGrpc.OpenRcaServiceStub
build
(io.grpc.Channel channel, io.grpc.CallOptions callOptions) void
streamCoreMetrics
(OrcaLoadReportRequest request, io.grpc.stub.StreamObserver<OrcaLoadReport> responseObserver) Methods inherited from class io.grpc.stub.AbstractAsyncStub
newStub, newStub
Methods inherited from class io.grpc.stub.AbstractStub
getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withExecutor, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOnReadyThreshold, withOption, withWaitForReady
-
Constructor Details
-
OpenRcaServiceStub
private OpenRcaServiceStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
-
-
Method Details
-
build
protected OpenRcaServiceGrpc.OpenRcaServiceStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions) - Specified by:
build
in classio.grpc.stub.AbstractStub<OpenRcaServiceGrpc.OpenRcaServiceStub>
-
streamCoreMetrics
public void streamCoreMetrics(OrcaLoadReportRequest request, io.grpc.stub.StreamObserver<OrcaLoadReport> responseObserver)
-