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.Server, org.apache.hadoop.hbase.shaded.protobuf.generated.AuthenticationProtos.AuthenticationService.BlockingInterface, org.apache.hadoop.hbase.shaded.protobuf.generated.AuthenticationProtos.AuthenticationService.Interface, 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.shaded.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 HBaseTestingUtil
    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, HBaseTestingUtil 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.client.AsyncClusterConnection
    getAsyncClusterConnection()
     
    org.apache.hadoop.hbase.shaded.protobuf.generated.AuthenticationProtos.GetAuthenticationTokenResponse
    getAuthenticationToken(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.AuthenticationProtos.GetAuthenticationTokenRequest request)
     
    org.apache.hadoop.hbase.ChoreService
    getChoreService()
     
    org.apache.hadoop.conf.Configuration
    getConfiguration()
     
    org.apache.hadoop.hbase.client.Connection
    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.shaded.protobuf.generated.AuthenticationProtos.WhoAmIResponse
    whoAmI(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller, org.apache.hadoop.hbase.shaded.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

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

    getAsyncConnection

  • Field Details

    • LOG

      private static final org.slf4j.Logger LOG

    • conf

      private org.apache.hadoop.conf.Configuration conf

    • TEST_UTIL

      private HBaseTestingUtil TEST_UTIL

    • rpcServer

      private org.apache.hadoop.hbase.ipc.RpcServerInterface rpcServer

    • isa

      private InetSocketAddress isa

    • zookeeper

      private org.apache.hadoop.hbase.zookeeper.ZKWatcher zookeeper

    • sleeper

      private org.apache.hadoop.hbase.util.Sleeper sleeper

    • started

      private boolean started

    • aborted

      private boolean aborted

    • stopped

      private boolean stopped

    • startcode

      private long startcode

  • 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.Connection 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.shaded.protobuf.generated.AuthenticationProtos.GetAuthenticationTokenResponse getAuthenticationToken(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.AuthenticationProtos.GetAuthenticationTokenRequest request) throws org.apache.hbase.thirdparty.com.google.protobuf.ServiceException
      Specified by:
      getAuthenticationToken in interface org.apache.hadoop.hbase.shaded.protobuf.generated.AuthenticationProtos.AuthenticationService.BlockingInterface
      Throws:
      org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

    • whoAmI

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

    • getChoreService

      public org.apache.hadoop.hbase.ChoreService getChoreService()
      Specified by:
      getChoreService 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

    • getAsyncClusterConnection

      public org.apache.hadoop.hbase.client.AsyncClusterConnection getAsyncClusterConnection()
      Specified by:
      getAsyncClusterConnection in interface org.apache.hadoop.hbase.Server