Package org.apache.hadoop.hbase.coprocessor

Class TestRpcCoprocessor.AuthorizationRpcObserver

java.lang.Object

org.apache.hadoop.hbase.coprocessor.TestRpcCoprocessor.AuthorizationRpcObserver

All Implemented Interfaces:

org.apache.hadoop.hbase.Coprocessor, org.apache.hadoop.hbase.coprocessor.RpcCoprocessor, org.apache.hadoop.hbase.coprocessor.RpcObserver

Enclosing class:

TestRpcCoprocessor

public static class TestRpcCoprocessor.AuthorizationRpcObserver
extends Object
implements org.apache.hadoop.hbase.coprocessor.RpcCoprocessor, org.apache.hadoop.hbase.coprocessor.RpcObserver

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.hadoop.hbase.Coprocessor

org.apache.hadoop.hbase.Coprocessor.State

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final AtomicInteger	ctPostAuthorization
(package private) final AtomicInteger	ctPreAuthorization
(package private) String	userName

Fields inherited from interface org.apache.hadoop.hbase.Coprocessor

PRIORITY_HIGHEST, PRIORITY_LOWEST, PRIORITY_SYSTEM, PRIORITY_USER, VERSION

Constructor Summary

Constructors

Constructor	Description
AuthorizationRpcObserver()

Method Summary

Modifier and Type	Method	Description
Optional<org.apache.hadoop.hbase.coprocessor.RpcObserver>	getRpcObserver()
void	postAuthorizeConnection(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RpcCoprocessorEnvironment> ctx, String userName, X509Certificate[] clientCertificateChain)
void	preAuthorizeConnection(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RpcCoprocessorEnvironment> ctx, org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.ConnectionHeader connectionHeader, InetAddress remoteAddr)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.hbase.Coprocessor

getServices, start, stop

Field Details

ctPostAuthorization

final AtomicInteger ctPostAuthorization

ctPreAuthorization

final AtomicInteger ctPreAuthorization

userName

String userName

Constructor Details

AuthorizationRpcObserver

public AuthorizationRpcObserver()

Method Details

getRpcObserver

public Optional<org.apache.hadoop.hbase.coprocessor.RpcObserver> getRpcObserver()

Specified by:

getRpcObserver in interface org.apache.hadoop.hbase.coprocessor.RpcCoprocessor

preAuthorizeConnection

public void preAuthorizeConnection(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RpcCoprocessorEnvironment> ctx,
 org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.ConnectionHeader connectionHeader,
 InetAddress remoteAddr)
                            throws IOException

Specified by:

preAuthorizeConnection in interface org.apache.hadoop.hbase.coprocessor.RpcObserver

Throws:

IOException

postAuthorizeConnection

public void postAuthorizeConnection(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RpcCoprocessorEnvironment> ctx,
 String userName,
 X509Certificate[] clientCertificateChain)
                             throws IOException

Specified by:

postAuthorizeConnection in interface org.apache.hadoop.hbase.coprocessor.RpcObserver

Throws:

IOException