Package org.apache.hadoop.hbase.security.token

Class TestTokenAuthentication.TokenServer

java.lang.Object
org.apache.hadoop.hbase.security.token.TokenProvider
org.apache.hadoop.hbase.security.token.TestTokenAuthentication.TokenServer
All Implemented Interfaces:
Runnable, org.apache.hadoop.hbase.Abortable, org.apache.hadoop.hbase.Coprocessor, org.apache.hadoop.hbase.coprocessor.RegionCoprocessor, org.apache.hadoop.hbase.protobuf.generated.AuthenticationProtos.AuthenticationService.BlockingInterface, org.apache.hadoop.hbase.protobuf.generated.AuthenticationProtos.AuthenticationService.Interface, org.apache.hadoop.hbase.Server, org.apache.hadoop.hbase.Stoppable
Enclosing class:
TestTokenAuthentication
private static class TestTokenAuthentication.TokenServer extends org.apache.hadoop.hbase.security.token.TokenProvider implements org.apache.hadoop.hbase.protobuf.generated.AuthenticationProtos.AuthenticationService.BlockingInterface, Runnable, org.apache.hadoop.hbase.Server
Basic server process for RPC authentication testing

  • 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
    private boolean
    aborted
     
    private org.apache.hadoop.conf.Configuration
    conf
     
    private InetSocketAddress
    isa
     
    private static final org.slf4j.Logger
    LOG
     
    private org.apache.hadoop.hbase.ipc.RpcServerInterface
    rpcServer
     
    private org.apache.hadoop.hbase.util.Sleeper
    sleeper
     
    private long
    startcode
     
    private boolean
    started
     
    private boolean
    stopped
     
    private HBaseTestingUtility
    TEST_UTIL
     
    private org.apache.hadoop.hbase.zookeeper.ZKWatcher
    zookeeper
     

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

    PRIORITY_HIGHEST, PRIORITY_LOWEST, PRIORITY_SYSTEM, PRIORITY_USER, VERSION

  • Constructor Summary

    Constructors
    Constructor
    Description
    TokenServer(org.apache.hadoop.conf.Configuration conf, HBaseTestingUtility TEST_UTIL)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    abort(String reason, Throwable error)
     
    org.apache.hadoop.hbase.client.Connection
    createConnection(org.apache.hadoop.conf.Configuration conf)
     
    InetSocketAddress
    getAddress()
     
    org.apache.hadoop.hbase.protobuf.generated.AuthenticationProtos.GetAuthenticationTokenResponse
    getAuthenticationToken(com.google.protobuf.RpcController controller, org.apache.hadoop.hbase.protobuf.generated.AuthenticationProtos.GetAuthenticationTokenRequest request)
     
    org.apache.hadoop.hbase.ChoreService
    getChoreService()
     
    org.apache.hadoop.hbase.client.ClusterConnection
    getClusterConnection()
     
    org.apache.hadoop.conf.Configuration
    getConfiguration()
     
    org.apache.hadoop.hbase.client.ClusterConnection
    getConnection()
     
    org.apache.hadoop.hbase.CoordinatedStateManager
    getCoordinatedStateManager()
     
    org.apache.hadoop.fs.FileSystem
    getFileSystem()
     
    org.apache.hadoop.security.token.SecretManager<? extends org.apache.hadoop.security.token.TokenIdentifier>
    getSecretManager()
     
    org.apache.hadoop.hbase.ServerName
    getServerName()
     
    org.apache.hadoop.hbase.zookeeper.ZKWatcher
    getZooKeeper()
     
    private void
    initialize()
     
    boolean
    isAborted()
     
    boolean
    isStarted()
     
    boolean
    isStopped()
     
    boolean
    isStopping()
     
    void
    run()
     
    void
    stop(String reason)
     
    org.apache.hadoop.hbase.protobuf.generated.AuthenticationProtos.WhoAmIResponse
    whoAmI(com.google.protobuf.RpcController controller, org.apache.hadoop.hbase.protobuf.generated.AuthenticationProtos.WhoAmIRequest request)
     

    Methods inherited from class org.apache.hadoop.hbase.security.token.TokenProvider

    getAuthenticationToken, getServices, start, stop, whoAmI

    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.Abortable

    abort

    Methods inherited from interface org.apache.hadoop.hbase.coprocessor.RegionCoprocessor

    getBulkLoadObserver, getEndpointObserver, getRegionObserver

  • Field Details

  • Constructor Details

  • Method Details

    • getConfiguration

      public org.apache.hadoop.conf.Configuration getConfiguration()
      Specified by:
      getConfiguration in interface org.apache.hadoop.hbase.Server

    • getConnection

      public org.apache.hadoop.hbase.client.ClusterConnection getConnection()
      Specified by:
      getConnection in interface org.apache.hadoop.hbase.Server

    • getZooKeeper

      public org.apache.hadoop.hbase.zookeeper.ZKWatcher getZooKeeper()
      Specified by:
      getZooKeeper in interface org.apache.hadoop.hbase.Server

    • getCoordinatedStateManager

      public org.apache.hadoop.hbase.CoordinatedStateManager getCoordinatedStateManager()
      Specified by:
      getCoordinatedStateManager in interface org.apache.hadoop.hbase.Server

    • isAborted

      public boolean isAborted()
      Specified by:
      isAborted in interface org.apache.hadoop.hbase.Abortable

    • getServerName

      public org.apache.hadoop.hbase.ServerName getServerName()
      Specified by:
      getServerName in interface org.apache.hadoop.hbase.Server

    • getFileSystem

      public org.apache.hadoop.fs.FileSystem getFileSystem()
      Specified by:
      getFileSystem in interface org.apache.hadoop.hbase.Server

    • isStopping

      public boolean isStopping()
      Specified by:
      isStopping in interface org.apache.hadoop.hbase.Server

    • abort

      public void abort(String reason, Throwable error)
      Specified by:
      abort in interface org.apache.hadoop.hbase.Abortable

    • initialize

      private void initialize() throws IOException
      Throws:
      IOException

    • run

      public void run()
      Specified by:
      run in interface Runnable

    • isStarted

      public boolean isStarted()

    • stop

      public void stop(String reason)
      Specified by:
      stop in interface org.apache.hadoop.hbase.Stoppable

    • isStopped

      public boolean isStopped()
      Specified by:
      isStopped in interface org.apache.hadoop.hbase.Stoppable

    • getAddress

      public InetSocketAddress getAddress()

    • getSecretManager

      public org.apache.hadoop.security.token.SecretManager<? extends org.apache.hadoop.security.token.TokenIdentifier> getSecretManager()

    • getAuthenticationToken

      public org.apache.hadoop.hbase.protobuf.generated.AuthenticationProtos.GetAuthenticationTokenResponse getAuthenticationToken(com.google.protobuf.RpcController controller, org.apache.hadoop.hbase.protobuf.generated.AuthenticationProtos.GetAuthenticationTokenRequest request) throws com.google.protobuf.ServiceException
      Specified by:
      getAuthenticationToken in interface org.apache.hadoop.hbase.protobuf.generated.AuthenticationProtos.AuthenticationService.BlockingInterface
      Throws:
      com.google.protobuf.ServiceException

    • whoAmI

      public org.apache.hadoop.hbase.protobuf.generated.AuthenticationProtos.WhoAmIResponse whoAmI(com.google.protobuf.RpcController controller, org.apache.hadoop.hbase.protobuf.generated.AuthenticationProtos.WhoAmIRequest request) throws com.google.protobuf.ServiceException
      Specified by:
      whoAmI in interface org.apache.hadoop.hbase.protobuf.generated.AuthenticationProtos.AuthenticationService.BlockingInterface
      Throws:
      com.google.protobuf.ServiceException

    • getChoreService

      public org.apache.hadoop.hbase.ChoreService getChoreService()
      Specified by:
      getChoreService in interface org.apache.hadoop.hbase.Server

    • getClusterConnection

      public org.apache.hadoop.hbase.client.ClusterConnection getClusterConnection()
      Specified by:
      getClusterConnection in interface org.apache.hadoop.hbase.Server

    • createConnection

      public org.apache.hadoop.hbase.client.Connection createConnection(org.apache.hadoop.conf.Configuration conf) throws IOException
      Specified by:
      createConnection in interface org.apache.hadoop.hbase.Server
      Throws:
      IOException