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
Modifier and Type | Field and Description |
---|---|
private boolean |
aborted |
private org.apache.hadoop.conf.Configuration |
conf |
private InetSocketAddress |
isa |
private static 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 |
Constructor and Description |
---|
TokenServer(org.apache.hadoop.conf.Configuration conf,
HBaseTestingUtil TEST_UTIL) |
Modifier and Type | Method and 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) |
getAuthenticationToken, getServices, start, stop, whoAmI
private static final org.slf4j.Logger LOG
private org.apache.hadoop.conf.Configuration conf
private HBaseTestingUtil TEST_UTIL
private org.apache.hadoop.hbase.ipc.RpcServerInterface rpcServer
private InetSocketAddress isa
private org.apache.hadoop.hbase.zookeeper.ZKWatcher zookeeper
private org.apache.hadoop.hbase.util.Sleeper sleeper
private boolean started
private boolean aborted
private boolean stopped
private long startcode
public TokenServer(org.apache.hadoop.conf.Configuration conf, HBaseTestingUtil TEST_UTIL) throws IOException
IOException
public org.apache.hadoop.conf.Configuration getConfiguration()
getConfiguration
in interface org.apache.hadoop.hbase.Server
public org.apache.hadoop.hbase.client.Connection getConnection()
getConnection
in interface org.apache.hadoop.hbase.Server
public org.apache.hadoop.hbase.zookeeper.ZKWatcher getZooKeeper()
getZooKeeper
in interface org.apache.hadoop.hbase.Server
public org.apache.hadoop.hbase.CoordinatedStateManager getCoordinatedStateManager()
getCoordinatedStateManager
in interface org.apache.hadoop.hbase.Server
public boolean isAborted()
isAborted
in interface org.apache.hadoop.hbase.Abortable
public org.apache.hadoop.hbase.ServerName getServerName()
getServerName
in interface org.apache.hadoop.hbase.Server
public org.apache.hadoop.fs.FileSystem getFileSystem()
getFileSystem
in interface org.apache.hadoop.hbase.Server
public boolean isStopping()
isStopping
in interface org.apache.hadoop.hbase.Server
public void abort(String reason, Throwable error)
abort
in interface org.apache.hadoop.hbase.Abortable
private void initialize() throws IOException
IOException
public boolean isStarted()
public void stop(String reason)
stop
in interface org.apache.hadoop.hbase.Stoppable
public boolean isStopped()
isStopped
in interface org.apache.hadoop.hbase.Stoppable
public InetSocketAddress getAddress()
public org.apache.hadoop.security.token.SecretManager<? extends org.apache.hadoop.security.token.TokenIdentifier> getSecretManager()
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
getAuthenticationToken
in interface org.apache.hadoop.hbase.shaded.protobuf.generated.AuthenticationProtos.AuthenticationService.BlockingInterface
org.apache.hbase.thirdparty.com.google.protobuf.ServiceException
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
whoAmI
in interface org.apache.hadoop.hbase.shaded.protobuf.generated.AuthenticationProtos.AuthenticationService.BlockingInterface
org.apache.hbase.thirdparty.com.google.protobuf.ServiceException
public org.apache.hadoop.hbase.ChoreService getChoreService()
getChoreService
in interface org.apache.hadoop.hbase.Server
public org.apache.hadoop.hbase.client.Connection createConnection(org.apache.hadoop.conf.Configuration conf) throws IOException
createConnection
in interface org.apache.hadoop.hbase.Server
IOException
public org.apache.hadoop.hbase.client.AsyncClusterConnection getAsyncClusterConnection()
getAsyncClusterConnection
in interface org.apache.hadoop.hbase.Server
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.