org.apache.storm.security.auth

Class SaslTransportPlugin

java.lang.Object

org.apache.storm.security.auth.SaslTransportPlugin

All Implemented Interfaces:

ITransportPlugin

Direct Known Subclasses:

DigestSaslTransportPlugin, KerberosSaslTransportPlugin, PlainSaslTransportPlugin

public abstract class SaslTransportPlugin
extends Object
implements ITransportPlugin

Base class for SASL authentication plugin.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SaslTransportPlugin.User

Field Summary

Fields

Modifier and Type	Field and Description
protected Configuration	login_conf
protected Map	storm_conf
protected ThriftConnectionType	type

Constructor Summary

Constructors

Constructor and Description
SaslTransportPlugin()

Method Summary

Modifier and Type	Method and Description
org.apache.thrift.server.TServer	getServer(org.apache.thrift.TProcessor processor) Create a server associated with a given port, service handler, and purpose
protected abstract org.apache.thrift.transport.TTransportFactory	getServerTransportFactory(boolean impersonationAllowed) All subclass must implement this method
void	prepare(ThriftConnectionType type, Map storm_conf, Configuration login_conf) Invoked once immediately after construction

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.storm.security.auth.ITransportPlugin

connect

Field Detail

type

protected ThriftConnectionType type

storm_conf

protected Map storm_conf

login_conf

protected Configuration login_conf

Constructor Detail

SaslTransportPlugin

public SaslTransportPlugin()

Method Detail

prepare

public void prepare(ThriftConnectionType type,
                    Map storm_conf,
                    Configuration login_conf)

Description copied from interface: ITransportPlugin

Invoked once immediately after construction

Specified by:

prepare in interface ITransportPlugin

Parameters:

type - the type of connection this will process.

storm_conf - Storm configuration

login_conf - login configuration

getServer

public org.apache.thrift.server.TServer getServer(org.apache.thrift.TProcessor processor)
                                           throws IOException,
                                                  org.apache.thrift.transport.TTransportException

Description copied from interface: ITransportPlugin

Create a server associated with a given port, service handler, and purpose

Specified by:

getServer in interface ITransportPlugin

Parameters:

processor - service handler

Returns:

server

Throws:

IOException

org.apache.thrift.transport.TTransportException

getServerTransportFactory

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

All subclass must implement this method

Parameters:

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

Returns:

server transport factory

Throws:

IOException