Package io.grpc.protobuf.services

Class HealthCheckingLoadBalancerFactory.HealthCheckState.HcStream

java.lang.Object

io.grpc.ClientCall.Listener<HealthCheckResponse>

io.grpc.protobuf.services.HealthCheckingLoadBalancerFactory.HealthCheckState.HcStream

Enclosing class:

HealthCheckingLoadBalancerFactory.HealthCheckState

private class HealthCheckingLoadBalancerFactory.HealthCheckState.HcStream
extends ClientCall.Listener<HealthCheckResponse>

Field Summary

Fields

Modifier and Type	Field	Description
private final ClientCall<HealthCheckRequest,HealthCheckResponse>	call
private boolean	callHasResponded
private final String	callServiceName
private final com.google.common.base.Stopwatch	stopwatch

Constructor Summary

Constructors

Constructor	Description
HcStream()

Method Summary

Modifier and Type	Method	Description
(package private) void	cancel(String msg)
(package private) void	handleResponse(HealthCheckResponse response)
(package private) void	handleStreamClosed(Status status)
void	onClose(Status status, Metadata trailers)	The ClientCall has been closed.
void	onMessage(HealthCheckResponse response)	A response message has been received.
(package private) void	start()
String	toString()

Methods inherited from class io.grpc.ClientCall.Listener

onHeaders, onReady

Methods inherited from class java.lang.Object

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

Field Details

call

private final ClientCall<HealthCheckRequest,HealthCheckResponse> call

callServiceName

private final String callServiceName

stopwatch

private final com.google.common.base.Stopwatch stopwatch

callHasResponded

private boolean callHasResponded

Constructor Details

HcStream

HcStream()

Method Details

start

void start()

cancel

void cancel(String msg)

onMessage

public void onMessage(HealthCheckResponse response)

Description copied from class: ClientCall.Listener

A response message has been received. May be called zero or more times depending on whether the call response is empty, a single message or a stream of messages.

Overrides:

onMessage in class ClientCall.Listener<HealthCheckResponse>

Parameters:

response - returned by the server

onClose

public void onClose(Status status,
 Metadata trailers)

Description copied from class: ClientCall.Listener

The ClientCall has been closed. Any additional calls to the ClientCall will not be processed by the server. No further receiving will occur and no further notifications will be made.

Since Metadata is not thread-safe, the caller must not access (read or write) trailers after this point.

If status returns false for Status.isOk(), then the call failed. An additional block of trailer metadata may be received at the end of the call from the server. An empty Metadata object is passed if no trailers are received.

This method should not throw. If this method throws, there is no way to be notified of the exception. Implementations should therefore be careful of exceptions which can accidentally leak resources.

Overrides:

onClose in class ClientCall.Listener<HealthCheckResponse>

Parameters:

status - the result of the remote call.

trailers - metadata provided at call completion.

handleResponse

void handleResponse(HealthCheckResponse response)

handleStreamClosed

void handleStreamClosed(Status status)

toString

public String toString()

Overrides:

toString in class Object