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 java.lang.Object implements XdsTransportFactory.EventHandler<DiscoveryResponse>
-
-
Field Summary
Fields Modifier and Type Field Description private XdsTransportFactory.StreamingCall<DiscoveryRequest,DiscoveryResponse>
call
private boolean
closed
private io.grpc.MethodDescriptor<DiscoveryRequest,DiscoveryResponse>
methodDescriptor
private java.util.Map<XdsResourceType<?>,java.lang.String>
respNonces
private boolean
responseReceived
-
Constructor Summary
Constructors Modifier Constructor Description private
AdsStream()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description private void
cleanUp()
private void
close(java.lang.Exception error)
(package private) void
handleRpcResponse(XdsResourceType<?> type, java.lang.String versionInfo, java.util.List<com.google.protobuf.Any> resources, java.lang.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, java.lang.String versionInfo, java.util.Collection<java.lang.String> resources, java.lang.String nonce, java.lang.String errorDetail)
Sends a discovery request with the givenversionInfo
,nonce
anderrorDetail
.(package private) void
sendDiscoveryRequest(XdsResourceType<?> type, java.util.Collection<java.lang.String> resources)
Sends a client-initiated discovery request.
-
-
-
Field Detail
-
responseReceived
private boolean responseReceived
-
closed
private boolean closed
-
respNonces
private final java.util.Map<XdsResourceType<?>,java.lang.String> respNonces
-
call
private final XdsTransportFactory.StreamingCall<DiscoveryRequest,DiscoveryResponse> call
-
methodDescriptor
private final io.grpc.MethodDescriptor<DiscoveryRequest,DiscoveryResponse> methodDescriptor
-
-
Method Detail
-
sendDiscoveryRequest
void sendDiscoveryRequest(XdsResourceType<?> type, java.lang.String versionInfo, java.util.Collection<java.lang.String> resources, java.lang.String nonce, @Nullable java.lang.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
final void sendDiscoveryRequest(XdsResourceType<?> type, java.util.Collection<java.lang.String> resources)
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
public void onRecvMessage(DiscoveryResponse response)
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, java.lang.String versionInfo, java.util.List<com.google.protobuf.Any> resources, java.lang.String nonce)
-
handleRpcStreamClosed
private void handleRpcStreamClosed(io.grpc.Status status)
-
close
private void close(java.lang.Exception error)
-
cleanUp
private void cleanUp()
-
-