alluxio.hub.manager.rpc.interceptor

Class HubAuthenticationInterceptor

java.lang.Object

alluxio.hub.manager.rpc.interceptor.HubAuthenticationInterceptor

All Implemented Interfaces:

io.grpc.ClientInterceptor

@ThreadSafe
public class HubAuthenticationInterceptor
extends Object
implements io.grpc.ClientInterceptor

Client side interceptor that is used to augment outgoing metadata with the API and secret keys for the channel that the RPC is being called on.

Field Summary

Fields

Modifier and Type	Field and Description
static io.grpc.Metadata.Key<String>	METADATA_API_KEY Metadata key for the API key.
static io.grpc.Metadata.Key<String>	METADATA_SECRET_KEY Metadata key for the Secret key.

Constructor Summary

Constructors

Constructor and Description
HubAuthenticationInterceptor(HubAuthentication hubAuthentication) Creates the client-side interceptor that augments outgoing metadata with API and secret keys for authentication.

Method Summary

Modifier and Type	Method and Description
<ReqT,RespT> io.grpc.ClientCall<ReqT,RespT>	interceptCall(io.grpc.MethodDescriptor<ReqT,RespT> method, io.grpc.CallOptions callOptions, io.grpc.Channel next)

Methods inherited from class java.lang.Object

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

Field Detail

METADATA_API_KEY

public static final io.grpc.Metadata.Key<String> METADATA_API_KEY

Metadata key for the API key.

METADATA_SECRET_KEY

public static final io.grpc.Metadata.Key<String> METADATA_SECRET_KEY

Metadata key for the Secret key.

Constructor Detail

HubAuthenticationInterceptor

public HubAuthenticationInterceptor(HubAuthentication hubAuthentication)

Creates the client-side interceptor that augments outgoing metadata with API and secret keys for authentication.

Parameters:

hubAuthentication - API and secret keys used by the Hub Manager for authentication

Method Detail

interceptCall

public <ReqT,RespT> io.grpc.ClientCall<ReqT,RespT> interceptCall(io.grpc.MethodDescriptor<ReqT,RespT> method,
                                                                 io.grpc.CallOptions callOptions,
                                                                 io.grpc.Channel next)

Specified by:

interceptCall in interface io.grpc.ClientInterceptor