Package io.grpc.grpclb

Class GrpclbState.LbStream

java.lang.Object

io.grpc.grpclb.GrpclbState.LbStream

All Implemented Interfaces:

StreamObserver<LoadBalanceResponse>

Enclosing class:

GrpclbState

private class GrpclbState.LbStream
extends Object
implements StreamObserver<LoadBalanceResponse>

Field Summary

Fields

Modifier and Type	Field	Description
(package private) boolean	closed
(package private) boolean	initialResponseReceived
(package private) StreamObserver<LoadBalanceRequest>	lbRequestWriter
(package private) final GrpclbClientLoadRecorder	loadRecorder
(package private) long	loadReportIntervalMillis
(package private) SynchronizationContext.ScheduledHandle	loadReportTimer
(package private) final LoadBalancerGrpc.LoadBalancerStub	stub

Constructor Summary

Constructors

Constructor	Description
LbStream(LoadBalancerGrpc.LoadBalancerStub stub)

Method Summary

Modifier and Type	Method	Description
private void	cleanUp()
(package private) void	close(Exception error)
private void	handleResponse(LoadBalanceResponse response)
private void	handleStreamClosed(Status error)
void	onCompleted()	Receives a notification of successful stream completion.
void	onError(Throwable error)	Receives a terminating error from the stream.
void	onNext(LoadBalanceResponse response)	Receives a value from the stream.
private void	scheduleNextLoadReport()
private void	sendLoadReport()
(package private) void	start()

Methods inherited from class java.lang.Object

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

Field Details

loadRecorder

final GrpclbClientLoadRecorder loadRecorder

stub

final LoadBalancerGrpc.LoadBalancerStub stub

lbRequestWriter

StreamObserver<LoadBalanceRequest> lbRequestWriter

initialResponseReceived

boolean initialResponseReceived

closed

boolean closed

loadReportIntervalMillis

long loadReportIntervalMillis

loadReportTimer

SynchronizationContext.ScheduledHandle loadReportTimer

Constructor Details

LbStream

LbStream(LoadBalancerGrpc.LoadBalancerStub stub)

Method Details

start

void start()

onNext

public void onNext(LoadBalanceResponse response)

Description copied from interface: StreamObserver

Receives a value from the stream.

Can be called many times but is never called after StreamObserver.onError(Throwable) or StreamObserver.onCompleted() are called.

Unary calls must invoke onNext at most once. Clients may invoke onNext at most once for server streaming calls, but may receive many onNext callbacks. Servers may invoke onNext at most once for client streaming calls, but may receive many onNext callbacks.

If an exception is thrown by an implementation the caller is expected to terminate the stream by calling StreamObserver.onError(Throwable) with the caught exception prior to propagating it.

Specified by:

onNext in interface StreamObserver<LoadBalanceResponse>

Parameters:

response - the value passed to the stream

onError

public void onError(Throwable error)

Description copied from interface: StreamObserver

Receives a terminating error from the stream.

May only be called once and if called it must be the last method called. In particular if an exception is thrown by an implementation of onError no further calls to any method are allowed.

t should be a StatusException or StatusRuntimeException, but other Throwable types are possible. Callers should generally convert from a Status via Status.asException() or Status.asRuntimeException(). Implementations should generally convert to a Status via Status.fromThrowable(Throwable).

Specified by:

onError in interface StreamObserver<LoadBalanceResponse>

Parameters:

error - the error occurred on the stream

onCompleted

public void onCompleted()

Description copied from interface: StreamObserver

Receives a notification of successful stream completion.

May only be called once and if called it must be the last method called. In particular if an exception is thrown by an implementation of onCompleted no further calls to any method are allowed.

Specified by:

onCompleted in interface StreamObserver<LoadBalanceResponse>

sendLoadReport

private void sendLoadReport()

scheduleNextLoadReport

private void scheduleNextLoadReport()

handleResponse

private void handleResponse(LoadBalanceResponse response)

handleStreamClosed

private void handleStreamClosed(Status error)

close

void close(Exception error)

cleanUp

private void cleanUp()