org.apache.hadoop.hbase.security

Class HBaseSaslRpcClient

java.lang.Object

org.apache.hadoop.hbase.security.AbstractHBaseSaslRpcClient

org.apache.hadoop.hbase.security.HBaseSaslRpcClient

@InterfaceAudience.Private
public class HBaseSaslRpcClient
extends AbstractHBaseSaslRpcClient

A utility class that encapsulates SASL logic for RPC client. Copied from org.apache.hadoop.security

Field Summary

Fields inherited from class org.apache.hadoop.hbase.security.AbstractHBaseSaslRpcClient

fallbackAllowed, saslClient, saslProps

Constructor Summary

Constructors

Constructor and Description
HBaseSaslRpcClient(AuthMethod method, org.apache.hadoop.security.token.Token<? extends org.apache.hadoop.security.token.TokenIdentifier> token, String serverPrincipal, boolean fallbackAllowed)
HBaseSaslRpcClient(AuthMethod method, org.apache.hadoop.security.token.Token<? extends org.apache.hadoop.security.token.TokenIdentifier> token, String serverPrincipal, boolean fallbackAllowed, String rpcProtection, boolean initStreamForCrypto)

Method Summary

Modifier and Type	Method and Description
InputStream	getInputStream() Get a SASL wrapped InputStream.
OutputStream	getOutputStream() Get a SASL wrapped OutputStream.
String	getSaslQOP()
void	initCryptoCipher(RPCProtos.CryptoCipherMeta cryptoCipherMeta, org.apache.hadoop.conf.Configuration conf)
boolean	saslConnect(InputStream inS, OutputStream outS) Do client side SASL authentication with server via the given InputStream and OutputStream

Methods inherited from class org.apache.hadoop.hbase.security.AbstractHBaseSaslRpcClient

createDigestSaslClient, createKerberosSaslClient, dispose, evaluateChallenge, getInitialResponse, isComplete

Methods inherited from class java.lang.Object

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

Constructor Detail

HBaseSaslRpcClient

public HBaseSaslRpcClient(AuthMethod method,
                          org.apache.hadoop.security.token.Token<? extends org.apache.hadoop.security.token.TokenIdentifier> token,
                          String serverPrincipal,
                          boolean fallbackAllowed)
                   throws IOException

Throws:

IOException

HBaseSaslRpcClient

public HBaseSaslRpcClient(AuthMethod method,
                          org.apache.hadoop.security.token.Token<? extends org.apache.hadoop.security.token.TokenIdentifier> token,
                          String serverPrincipal,
                          boolean fallbackAllowed,
                          String rpcProtection,
                          boolean initStreamForCrypto)
                   throws IOException

Throws:

IOException

Method Detail

saslConnect

public boolean saslConnect(InputStream inS,
                           OutputStream outS)
                    throws IOException

Do client side SASL authentication with server via the given InputStream and OutputStream

Parameters:

inS - InputStream to use

outS - OutputStream to use

Returns:

true if connection is set up, or false if needs to switch to simple Auth.

Throws:

IOException

getSaslQOP

public String getSaslQOP()

initCryptoCipher

public void initCryptoCipher(RPCProtos.CryptoCipherMeta cryptoCipherMeta,
                             org.apache.hadoop.conf.Configuration conf)
                      throws IOException

Throws:

IOException

getInputStream

public InputStream getInputStream()
                           throws IOException

Get a SASL wrapped InputStream. Can be called only after saslConnect() has been called.

Returns:

a SASL wrapped InputStream

Throws:

IOException

getOutputStream

public OutputStream getOutputStream()
                             throws IOException

Get a SASL wrapped OutputStream. Can be called only after saslConnect() has been called.

Returns:

a SASL wrapped OutputStream

Throws:

IOException