Package org.apache.storm.security.auth
Class SimpleTransportPlugin
java.lang.Object
org.apache.storm.security.auth.SimpleTransportPlugin
- All Implemented Interfaces:
ITransportPlugin
- Direct Known Subclasses:
SingleUserSimpleTransport
Simple transport for Thrift plugin.
This plugin is designed to be backward compatible with existing Storm code.
-
Field Summary
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionorg.apache.storm.thrift.transport.TTransport
Connect to the specified server via framed transport.protected Subject
Get default subject.int
getPort()
Get port.org.apache.storm.thrift.server.TServer
getServer
(org.apache.storm.thrift.TProcessor processor) Create a server associated with a given port, service handler, and purpose.void
prepare
(ThriftConnectionType type, Map<String, Object> topoConf) 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
areWorkerTokensSupported
-
Field Details
-
type
-
topoConf
-
-
Constructor Details
-
SimpleTransportPlugin
public SimpleTransportPlugin()
-
-
Method Details
-
prepare
Description copied from interface:ITransportPlugin
Invoked once immediately after construction.- Specified by:
prepare
in interfaceITransportPlugin
- Parameters:
type
- the type of connection this will process.topoConf
- Storm configuration
-
getServer
public org.apache.storm.thrift.server.TServer getServer(org.apache.storm.thrift.TProcessor processor) throws IOException, org.apache.storm.thrift.transport.TTransportException Description copied from interface:ITransportPlugin
Create a server associated with a given port, service handler, and purpose.- Specified by:
getServer
in interfaceITransportPlugin
- Parameters:
processor
- service handler- Returns:
- server
- Throws:
IOException
org.apache.storm.thrift.transport.TTransportException
-
connect
public org.apache.storm.thrift.transport.TTransport connect(org.apache.storm.thrift.transport.TTransport transport, String serverHost, String asUser) throws org.apache.storm.thrift.transport.TTransportException Connect to the specified server via framed transport.- Specified by:
connect
in interfaceITransportPlugin
- Parameters:
transport
- The underlying Thrift transportserverHost
- unusedasUser
- unused- Throws:
org.apache.storm.thrift.transport.TTransportException
-
getDefaultSubject
Get default subject.- Returns:
- the subject that will be used for all connections
-
getPort
public int getPort()Description copied from interface:ITransportPlugin
Get port.- Specified by:
getPort
in interfaceITransportPlugin
- Returns:
- The port this transport is using. This is not known until
ITransportPlugin.getServer(org.apache.storm.thrift.TProcessor)
has been called
-