io.token.rpc.interceptor

Class SimpleInterceptor<ReqT,ResT>

java.lang.Object

io.token.rpc.interceptor.SimpleInterceptor<ReqT,ResT>

Type Parameters:

ReqT - request type

ResT - response type

Direct Known Subclasses:

LoggingInterceptor, MetadataInterceptor, MetricsInterceptor

public abstract class SimpleInterceptor<ReqT,ResT>
extends java.lang.Object

Simple interceptor that works on both client and server. Hides the complexity of dealing with gRPC interceptors.

Constructor Summary

Constructors

Constructor and Description
SimpleInterceptor()

Method Summary

Modifier and Type	Method and Description
io.grpc.Status	onComplete(io.grpc.Status status, ReqT req, ResT res, io.grpc.Metadata trailers) Invoked when request is finished.
void	onHalfClose(ReqT req, io.grpc.Metadata headers) gRPC invokes the actual method implementation in the onHalfClose method.
void	onStart(ReqT req, io.grpc.Metadata headers) Invoked when request is starting.

Methods inherited from class java.lang.Object

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

Constructor Detail

SimpleInterceptor

public SimpleInterceptor()

Method Detail

onStart

public void onStart(ReqT req,
                    io.grpc.Metadata headers)

Invoked when request is starting.

Parameters:

req - proto request

headers - request metadata

onHalfClose

public void onHalfClose(ReqT req,
                        io.grpc.Metadata headers)

gRPC invokes the actual method implementation in the onHalfClose method. They basically delay the call until client indicated that it is done with the request and waiting for the reply.

The method can potentially be invoked on a thread different from the one that called onStart(ReqT, io.grpc.Metadata). So all the features that rely on thread local for processing need to perform the initialization in this method and NOT in onStart(ReqT, io.grpc.Metadata).

Parameters:

req - proto request

headers - request metadata

onComplete

public io.grpc.Status onComplete(io.grpc.Status status,
                                 ReqT req,
                                 @Nullable
                                 ResT res,
                                 @Nullable
                                 io.grpc.Metadata trailers)

Invoked when request is finished.

Parameters:

status - request status, if not successful response is not going to be present

req - proto request

trailers - response metadata

res - proto response

Returns:

processed status