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

Fields

Modifier and Type	Field	Description
private final XdsTransportFactory.StreamingCall<DiscoveryRequest,DiscoveryResponse>	call
private boolean	closed
private final io.grpc.MethodDescriptor<DiscoveryRequest,DiscoveryResponse>	methodDescriptor
private final Map<XdsResourceType<?>,String>	respNonces
private boolean	responseReceived

Constructor Summary

Constructors

Modifier	Constructor	Description
private	AdsStream()

Method Summary

Modifier and Type	Method	Description
private void	cleanUp()
private void	close(Exception error)
(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 given versionInfo, nonce and errorDetail.
(package private) final void	sendDiscoveryRequest(XdsResourceType<?> type, Collection<String> resources)	Sends a client-initiated discovery request.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

responseReceived

private boolean responseReceived

closed

private boolean closed

respNonces

private final Map<XdsResourceType<?>,String> respNonces

call

private final XdsTransportFactory.StreamingCall<DiscoveryRequest,DiscoveryResponse> call

methodDescriptor

private final io.grpc.MethodDescriptor<DiscoveryRequest,DiscoveryResponse> 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 given versionInfo, nonce and errorDetail. Used for reacting to a specific discovery response. For client-initiated discovery requests, use sendDiscoveryRequest(XdsResourceType, Collection).

sendDiscoveryRequest

final void sendDiscoveryRequest(XdsResourceType<?> type,
 Collection<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 see XdsTransportFactory.StreamingCall.isReady(). Application is free to ignore it.

Specified by:

onReady in interface XdsTransportFactory.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 interface XdsTransportFactory.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 interface XdsTransportFactory.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

private void close(Exception error)

cleanUp

private void cleanUp()