io.token.rpc.interceptor

Class LoggingInterceptor<ReqT,ResT>

java.lang.Object

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

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

public final class LoggingInterceptor<ReqT,ResT>
extends SimpleInterceptor<ReqT,ResT>

Logs RPC request/responses. The messages are logged with the respective Service logger, so that the logging level can be tweaked by service.

Constructor Summary

Constructors

Constructor and Description
LoggingInterceptor(Endpoint endpoint, io.grpc.MethodDescriptor<ReqT,ResT> method) Creates an instance.

Method Summary

Modifier and Type	Method and Description
static InterceptorFactory	newFactory(Endpoint endpoint) Creates an InterceptorFactory with a given endpoint.
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

LoggingInterceptor

public LoggingInterceptor(Endpoint endpoint,
                          io.grpc.MethodDescriptor<ReqT,ResT> method)

Creates an instance.

Parameters:

endpoint - endpoint

method - method

Method Detail

newFactory

public static InterceptorFactory newFactory(Endpoint endpoint)

Creates an InterceptorFactory with a given endpoint.

Parameters:

endpoint - endpoint

Returns:

InterceptorFactory instance

onStart

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

Description copied from class: SimpleInterceptor

Invoked when request is starting.

Overrides:

onStart in class SimpleInterceptor<ReqT,ResT>

Parameters:

req - proto request

headers - request metadata

onHalfClose

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

Description copied from class: SimpleInterceptor

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 SimpleInterceptor.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 SimpleInterceptor.onStart(ReqT, io.grpc.Metadata).

Overrides:

onHalfClose in class SimpleInterceptor<ReqT,ResT>

Parameters:

req - proto request

headers - request metadata

onComplete

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

Description copied from class: SimpleInterceptor

Invoked when request is finished.

Overrides:

onComplete in class SimpleInterceptor<ReqT,ResT>

Parameters:

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

req - proto request

res - proto response

trailers - response metadata

Returns:

processed status