Class LoadReportClient.LrsStream

java.lang.Object

io.grpc.xds.client.LoadReportClient.LrsStream

All Implemented Interfaces:

XdsTransportFactory.EventHandler<LoadStatsResponse>

Enclosing class:

LoadReportClient

private final class LoadReportClient.LrsStream
extends Object
implements XdsTransportFactory.EventHandler<LoadStatsResponse>

Field Summary

Fields

Modifier and Type	Field	Description
private final XdsTransportFactory.StreamingCall<LoadStatsRequest, LoadStatsResponse>	call
(package private) boolean	closed
(package private) List<String>	clusterNames
(package private) boolean	initialResponseReceived
(package private) long	intervalNano
(package private) io.grpc.SynchronizationContext.ScheduledHandle	loadReportTimer
(package private) boolean	reportAllClusters

Constructor Summary

Constructors

Constructor	Description
LrsStream()

Method Summary

Modifier and Type	Method	Description
private ClusterStats	buildClusterStats(Stats.ClusterStats stats)
private void	cleanUp()
private void	close(Exception error)
(package private) void	handleRpcResponse(List<String> clusters, boolean sendAllClusters, long loadReportIntervalNano)
private void	handleStreamClosed(io.grpc.Status status)
void	onReady()	Called when the stream is ready to send additional messages.
void	onRecvMessage(LoadStatsResponse response)	Called when a message is received on the stream.
void	onStatusReceived(io.grpc.Status status)	Called when status is received on the stream.
private void	scheduleNextLoadReport()
private void	sendLoadReport()
(package private) void	sendLoadStatsRequest(List<Stats.ClusterStats> clusterStatsList)

Methods inherited from class Object

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

Field Details

initialResponseReceived

boolean initialResponseReceived

closed

boolean closed

intervalNano

long intervalNano

reportAllClusters

boolean reportAllClusters

clusterNames

List<String> clusterNames

loadReportTimer

io.grpc.SynchronizationContext.ScheduledHandle loadReportTimer

call

private final XdsTransportFactory.StreamingCall<LoadStatsRequest, LoadStatsResponse> call

Constructor Details

LrsStream

LrsStream()

Method Details

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<LoadStatsResponse>

onRecvMessage

public void onRecvMessage(LoadStatsResponse response)

Description copied from interface: XdsTransportFactory.EventHandler

Called when a message is received on the stream.

Specified by:

onRecvMessage in interface XdsTransportFactory.EventHandler<LoadStatsResponse>

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<LoadStatsResponse>

sendLoadStatsRequest

void sendLoadStatsRequest(List<Stats.ClusterStats> clusterStatsList)

handleRpcResponse

void handleRpcResponse(List<String> clusters,
 boolean sendAllClusters,
 long loadReportIntervalNano)

sendLoadReport

private void sendLoadReport()

scheduleNextLoadReport

private void scheduleNextLoadReport()

handleStreamClosed

private void handleStreamClosed(io.grpc.Status status)

close

private void close(Exception error)

cleanUp

private void cleanUp()

buildClusterStats

private ClusterStats buildClusterStats(Stats.ClusterStats stats)