io.token.rpc.interceptor

Class MetricsInterceptor<ReqT,ResT>

java.lang.Object

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

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

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

Logs request/response metrics.

Method Summary

Modifier and Type	Method and Description
static InterceptorFactory	newFactory(Endpoint endpoint, com.codahale.metrics.MetricRegistry metrics) Creates a new InterceptorFactory.
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

Method Detail

newFactory

public static InterceptorFactory newFactory(Endpoint endpoint,
                                            com.codahale.metrics.MetricRegistry metrics)

Creates a new InterceptorFactory.

Parameters:

endpoint - endpoint

metrics - metrics

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