alluxio.hub.manager.rpc.observer

Class RequestStreamObserver<ReqT,ResT>

java.lang.Object

alluxio.hub.manager.rpc.observer.RequestStreamObserver<ReqT,ResT>

Type Parameters:

ReqT - request object type

ResT - response object type

All Implemented Interfaces:

io.grpc.stub.StreamObserver<ReqT>

public abstract class RequestStreamObserver<ReqT,ResT>
extends Object
implements io.grpc.stub.StreamObserver<ReqT>

This stream observer listens for requests and returns responses to the Hosted Hub.

Field Summary

Fields

Modifier and Type	Field and Description
static org.slf4j.Logger	LOG

Constructor Summary

Constructors

Constructor and Description
RequestStreamObserver()

Method Summary

Modifier and Type	Method and Description
abstract ResT	exec(ReqT req) Executes on a request to return a response.
abstract void	handleError(String message, Throwable t) Handles errors depending on the type.
void	onCompleted() Properly shutdown the stream observer.
void	onError(Throwable t) Handles errors that occur and attempts to restart the stream observer if possible.
void	onNext(ReqT request) Generates a response and sends it through the response stream observer.
abstract void	restart() Handles restarting the request stream observer.
void	start(io.grpc.stub.StreamObserver<ResT> responseStreamObserver, ResT resp) Initialize the response stream observer.

Methods inherited from class java.lang.Object

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

Field Detail

LOG

public static final org.slf4j.Logger LOG

Constructor Detail

RequestStreamObserver

public RequestStreamObserver()

Method Detail

onNext

public void onNext(ReqT request)

Generates a response and sends it through the response stream observer.

Specified by:

onNext in interface io.grpc.stub.StreamObserver<ReqT>

Parameters:

request - request object to execute on

onError

public void onError(Throwable t)

Handles errors that occur and attempts to restart the stream observer if possible.

Specified by:

onError in interface io.grpc.stub.StreamObserver<ReqT>

Parameters:

t - Throwable

onCompleted

public void onCompleted()

Properly shutdown the stream observer.

Specified by:

onCompleted in interface io.grpc.stub.StreamObserver<ReqT>

start

public void start(io.grpc.stub.StreamObserver<ResT> responseStreamObserver,
                  ResT resp)

Initialize the response stream observer.

Parameters:

responseStreamObserver - response stream observer

resp - response object

exec

public abstract ResT exec(ReqT req)

Executes on a request to return a response.

Parameters:

req - request object to execute on

Returns:

response object

restart

public abstract void restart()

Handles restarting the request stream observer.

handleError

public abstract void handleError(String message,
                                 Throwable t)

Handles errors depending on the type.

Parameters:

message - message to log

t - Throwable object