org.apache.storm.security.auth.plain

Class PlainSaslTransportPlugin

java.lang.Object

org.apache.storm.security.auth.SaslTransportPlugin

org.apache.storm.security.auth.plain.PlainSaslTransportPlugin

All Implemented Interfaces:

ITransportPlugin

public class PlainSaslTransportPlugin
extends SaslTransportPlugin

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.storm.security.auth.SaslTransportPlugin

SaslTransportPlugin.User

Field Summary

Fields

Modifier and Type	Field and Description
static String	PLAIN

Fields inherited from class org.apache.storm.security.auth.SaslTransportPlugin

login_conf, storm_conf, type

Constructor Summary

Constructors

Constructor and Description
PlainSaslTransportPlugin()

Method Summary

Modifier and Type	Method and Description
org.apache.thrift.transport.TTransport	connect(org.apache.thrift.transport.TTransport transport, String serverHost, String asUser) Connect to the specified server via framed transport
protected org.apache.thrift.transport.TTransportFactory	getServerTransportFactory(boolean impersonationAllowed) All subclass must implement this method

Methods inherited from class org.apache.storm.security.auth.SaslTransportPlugin

getServer, prepare

Methods inherited from class java.lang.Object

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

Field Detail

PLAIN

public static final String PLAIN

See Also:

Constant Field Values

Constructor Detail

PlainSaslTransportPlugin

public PlainSaslTransportPlugin()

Method Detail

getServerTransportFactory

protected org.apache.thrift.transport.TTransportFactory getServerTransportFactory(boolean impersonationAllowed)
                                                                           throws IOException

Description copied from class: SaslTransportPlugin

All subclass must implement this method

Specified by:

getServerTransportFactory in class SaslTransportPlugin

Parameters:

impersonationAllowed - true if SASL impersonation should be allowed, else false.

Returns:

server transport factory

Throws:

IOException

connect

public org.apache.thrift.transport.TTransport connect(org.apache.thrift.transport.TTransport transport,
                                                      String serverHost,
                                                      String asUser)
                                               throws IOException,
                                                      org.apache.thrift.transport.TTransportException

Description copied from interface: ITransportPlugin

Connect to the specified server via framed transport

Parameters:

transport - The underlying Thrift transport.

serverHost - server host

asUser - the user as which the connection should be established, and all the subsequent actions should be executed. Only applicable when using secure storm cluster. A null/blank value here will just indicate to use the logged in user.

Throws:

IOException

org.apache.thrift.transport.TTransportException