Class AggregatedDiscoveryServiceGrpc.AggregatedDiscoveryServiceStub
java.lang.Object
io.grpc.stub.AbstractStub<AggregatedDiscoveryServiceGrpc.AggregatedDiscoveryServiceStub>
io.grpc.stub.AbstractAsyncStub<AggregatedDiscoveryServiceGrpc.AggregatedDiscoveryServiceStub>
io.envoyproxy.envoy.service.discovery.v3.AggregatedDiscoveryServiceGrpc.AggregatedDiscoveryServiceStub
- Enclosing class:
AggregatedDiscoveryServiceGrpc
public static final class AggregatedDiscoveryServiceGrpc.AggregatedDiscoveryServiceStub
extends io.grpc.stub.AbstractAsyncStub<AggregatedDiscoveryServiceGrpc.AggregatedDiscoveryServiceStub>
A stub to allow clients to do asynchronous rpc calls to service AggregatedDiscoveryService.
See https://github.com/envoyproxy/envoy-api#apis for a description of the role of ADS and how it is intended to be used by a management server. ADS requests have the same structure as their singleton xDS counterparts, but can multiplex many resource types on a single stream. The type_url in the DiscoveryRequest/DiscoveryResponse provides sufficient information to recover the multiplexed singleton APIs at the Envoy instance and management server.
-
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
AggregatedDiscoveryServiceStub
(io.grpc.Channel channel, io.grpc.CallOptions callOptions) -
Method Summary
Modifier and TypeMethodDescriptionbuild
(io.grpc.Channel channel, io.grpc.CallOptions callOptions) io.grpc.stub.StreamObserver
<DeltaDiscoveryRequest> deltaAggregatedResources
(io.grpc.stub.StreamObserver<DeltaDiscoveryResponse> responseObserver) io.grpc.stub.StreamObserver
<DiscoveryRequest> streamAggregatedResources
(io.grpc.stub.StreamObserver<DiscoveryResponse> responseObserver) This is a gRPC-only API.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
-
AggregatedDiscoveryServiceStub
private AggregatedDiscoveryServiceStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
-
-
Method Details
-
build
protected AggregatedDiscoveryServiceGrpc.AggregatedDiscoveryServiceStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions) - Specified by:
build
in classio.grpc.stub.AbstractStub<AggregatedDiscoveryServiceGrpc.AggregatedDiscoveryServiceStub>
-
streamAggregatedResources
public io.grpc.stub.StreamObserver<DiscoveryRequest> streamAggregatedResources(io.grpc.stub.StreamObserver<DiscoveryResponse> responseObserver) This is a gRPC-only API.
-
deltaAggregatedResources
public io.grpc.stub.StreamObserver<DeltaDiscoveryRequest> deltaAggregatedResources(io.grpc.stub.StreamObserver<DeltaDiscoveryResponse> responseObserver)
-