org.apache.arrow.flight.grpc

Class ServerInterceptorAdapter

java.lang.Object

org.apache.arrow.flight.grpc.ServerInterceptorAdapter

All Implemented Interfaces:

io.grpc.ServerInterceptor

public class ServerInterceptorAdapter
extends Object
implements io.grpc.ServerInterceptor

An adapter between Flight middleware and a gRPC interceptor.

This is implemented as a single gRPC interceptor that runs all Flight server middleware sequentially. Flight middleware instances are stored in the gRPC Context so their state is accessible later.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ServerInterceptorAdapter.KeyFactory<T extends FlightServerMiddleware> A combination of a middleware Key and factory.

Field Summary

Fields

Modifier and Type	Field and Description
static io.grpc.Context.Key<Map<FlightServerMiddleware.Key<?>,FlightServerMiddleware>>	SERVER_MIDDLEWARE_KEY The Context.Key that stores the Flight middleware active for a particular call.

Constructor Summary

Constructors

Constructor and Description
ServerInterceptorAdapter(List<ServerInterceptorAdapter.KeyFactory<?>> factories)

Method Summary

Modifier and Type	Method and Description
<ReqT,RespT> io.grpc.ServerCall.Listener<ReqT>	interceptCall(io.grpc.ServerCall<ReqT,RespT> call, io.grpc.Metadata headers, io.grpc.ServerCallHandler<ReqT,RespT> next)

Methods inherited from class java.lang.Object

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

Field Detail

SERVER_MIDDLEWARE_KEY

public static final io.grpc.Context.Key<Map<FlightServerMiddleware.Key<?>,FlightServerMiddleware>> SERVER_MIDDLEWARE_KEY

The Context.Key that stores the Flight middleware active for a particular call.

Applications should not use this directly. Instead, see CallContext#getMiddleware(Key).

Constructor Detail

ServerInterceptorAdapter

public ServerInterceptorAdapter(List<ServerInterceptorAdapter.KeyFactory<?>> factories)

Method Detail

interceptCall

public <ReqT,RespT> io.grpc.ServerCall.Listener<ReqT> interceptCall(io.grpc.ServerCall<ReqT,RespT> call,
                                                                    io.grpc.Metadata headers,
                                                                    io.grpc.ServerCallHandler<ReqT,RespT> next)

Specified by:

interceptCall in interface io.grpc.ServerInterceptor