io.token.rpc.interceptor

Class MetadataInterceptor<ReqT,ResT>

java.lang.Object

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

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

public class MetadataInterceptor<ReqT,ResT>
extends SimpleInterceptor<ReqT,ResT>

Appends metadata (headers) to a call.

Constructor Summary

Constructors

Constructor and Description
MetadataInterceptor(io.grpc.Metadata metadata) Creates an instance.

Method Summary

Modifier and Type	Method and Description
static InterceptorFactory	newFactory(io.grpc.Metadata metadata) Creates an InterceptorFactory with a given endpoint.
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 io.token.rpc.interceptor.SimpleInterceptor

onComplete

Methods inherited from class java.lang.Object

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

Constructor Detail

MetadataInterceptor

public MetadataInterceptor(io.grpc.Metadata metadata)

Creates an instance.

Parameters:

metadata - to add

Method Detail

newFactory

public static InterceptorFactory newFactory(io.grpc.Metadata metadata)

Creates an InterceptorFactory with a given endpoint.

Parameters:

metadata - metadata

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