Package io.grpc.xds.client
Class ControlPlaneClient.AdsStream
java.lang.Object
io.grpc.xds.client.ControlPlaneClient.AdsStream
- All Implemented Interfaces:
XdsTransportFactory.EventHandler<DiscoveryResponse>
- Enclosing class:
ControlPlaneClient
private class ControlPlaneClient.AdsStream
extends Object
implements XdsTransportFactory.EventHandler<DiscoveryResponse>
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate final XdsTransportFactory.StreamingCall
<DiscoveryRequest, DiscoveryResponse> private boolean
private final io.grpc.MethodDescriptor
<DiscoveryRequest, DiscoveryResponse> private final Map
<XdsResourceType<?>, String> private boolean
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprivate void
cleanUp()
private void
(package private) final void
handleRpcResponse
(XdsResourceType<?> type, String versionInfo, List<com.google.protobuf.Any> resources, String nonce) private void
handleRpcStreamClosed
(io.grpc.Status status) void
onReady()
Called when the stream is ready to send additional messages.void
onRecvMessage
(DiscoveryResponse response) Called when a message is received on the stream.void
onStatusReceived
(io.grpc.Status status) Called when status is received on the stream.(package private) void
sendDiscoveryRequest
(XdsResourceType<?> type, String versionInfo, Collection<String> resources, String nonce, String errorDetail) Sends a discovery request with the givenversionInfo
,nonce
anderrorDetail
.(package private) final void
sendDiscoveryRequest
(XdsResourceType<?> type, Collection<String> resources) Sends a client-initiated discovery request.
-
Field Details
-
responseReceived
private boolean responseReceived -
closed
private boolean closed -
respNonces
-
call
-
methodDescriptor
-
-
Constructor Details
-
AdsStream
private AdsStream()
-
-
Method Details
-
sendDiscoveryRequest
void sendDiscoveryRequest(XdsResourceType<?> type, String versionInfo, Collection<String> resources, String nonce, @Nullable String errorDetail) Sends a discovery request with the givenversionInfo
,nonce
anderrorDetail
. Used for reacting to a specific discovery response. For client-initiated discovery requests, usesendDiscoveryRequest(XdsResourceType, Collection)
. -
sendDiscoveryRequest
Sends a client-initiated discovery request. -
onReady
public void onReady()Description copied from interface:XdsTransportFactory.EventHandler
Called when the stream is ready to send additional messages. If called the library use this handler to trigger resource arrival timeout, also seeXdsTransportFactory.StreamingCall.isReady()
. Application is free to ignore it.- Specified by:
onReady
in interfaceXdsTransportFactory.EventHandler<DiscoveryResponse>
-
onRecvMessage
Description copied from interface:XdsTransportFactory.EventHandler
Called when a message is received on the stream.- Specified by:
onRecvMessage
in interfaceXdsTransportFactory.EventHandler<DiscoveryResponse>
-
onStatusReceived
public void onStatusReceived(io.grpc.Status status) Description copied from interface:XdsTransportFactory.EventHandler
Called when status is received on the stream.- Specified by:
onStatusReceived
in interfaceXdsTransportFactory.EventHandler<DiscoveryResponse>
-
handleRpcResponse
final void handleRpcResponse(XdsResourceType<?> type, String versionInfo, List<com.google.protobuf.Any> resources, String nonce) -
handleRpcStreamClosed
private void handleRpcStreamClosed(io.grpc.Status status) -
close
-
cleanUp
private void cleanUp()
-